(function (_, kotlin_org_jetbrains_kotlinx_kotlinx_coroutines_core, kotlin_kotlin, kotlin_io_ktor_ktor_utils) { 'use strict'; //region block: imports var LinkedListNode = kotlin_org_jetbrains_kotlinx_kotlinx_coroutines_core.$_$.q1; var classMeta = kotlin_kotlin.$_$.mb; var setMetadataFor = kotlin_kotlin.$_$.yc; var CopyOnWriteHashMap = kotlin_io_ktor_ktor_utils.$_$.d; var equals = kotlin_kotlin.$_$.pb; var THROW_CCE = kotlin_kotlin.$_$.ji; var addSuppressed = kotlin_kotlin.$_$.xi; var Unit_instance = kotlin_kotlin.$_$.m5; var protoOf = kotlin_kotlin.$_$.xc; var VOID = kotlin_kotlin.$_$.f; //endregion //region block: pre-declaration setMetadataFor(HandlerRegistration, 'HandlerRegistration', classMeta, LinkedListNode); setMetadataFor(Events, 'Events', classMeta, VOID, VOID, Events); setMetadataFor(EventDefinition, 'EventDefinition', classMeta, VOID, VOID, EventDefinition); //endregion function HandlerRegistration() { } function Events() { this.z32_1 = new CopyOnWriteHashMap(); } protoOf(Events).a33 = function (definition, value) { var exception = null; var tmp0_safe_receiver = this.z32_1.e2o(definition); if (tmp0_safe_receiver == null) null; else { // Inline function 'kotlinx.coroutines.internal.LinkedListHead.forEach' call var cur = tmp0_safe_receiver.nt_1; while (!equals(cur, tmp0_safe_receiver)) { if (cur instanceof HandlerRegistration) { // Inline function 'io.ktor.events.Events.raise.' call var registration = cur; try { var tmp = registration.e33_1; (typeof tmp === 'function' ? tmp : THROW_CCE())(value); } catch ($p) { if ($p instanceof Error) { var e = $p; var tmp0_safe_receiver_0 = exception; var tmp_0; if (tmp0_safe_receiver_0 == null) { tmp_0 = null; } else { addSuppressed(tmp0_safe_receiver_0, e); tmp_0 = Unit_instance; } if (tmp_0 == null) { // Inline function 'kotlin.run' call // Inline function 'kotlin.contracts.contract' call exception = e; } } else { throw $p; } } } cur = cur.nt_1; } } var tmp1_safe_receiver = exception; if (tmp1_safe_receiver == null) null; else { // Inline function 'kotlin.let' call // Inline function 'kotlin.contracts.contract' call throw tmp1_safe_receiver; } }; function EventDefinition() { } //region block: exports _.$_$ = _.$_$ || {}; _.$_$.a = EventDefinition; _.$_$.b = Events; //endregion return _; }(module.exports, require('./kotlinx-coroutines-core.js'), require('./kotlin-kotlin-stdlib.js'), require('./ktor-ktor-utils.js'))); //# sourceMappingURL=ktor-ktor-events.js.map