| OLD | NEW |
| 1 // Generated by dart2js, the Dart to JavaScript compiler version: 1.10.0-edge.45
075. | 1 // Generated by dart2js, the Dart to JavaScript compiler version: 1.10.0-edge.45
075. |
| 2 // The code supports the following hooks: | 2 // The code supports the following hooks: |
| 3 // dartPrint(message): | 3 // dartPrint(message): |
| 4 // if this function is defined it is called instead of the Dart [print] | 4 // if this function is defined it is called instead of the Dart [print] |
| 5 // method. | 5 // method. |
| 6 // | 6 // |
| 7 // dartMainRunner(main, args): | 7 // dartMainRunner(main, args): |
| 8 // if this function is defined, the Dart [main] method will not be invoked | 8 // if this function is defined, the Dart [main] method will not be invoked |
| 9 // directly. Instead, a closure that will invoke [main], and its arguments | 9 // directly. Instead, a closure that will invoke [main], and its arguments |
| 10 // [args] is passed to [dartMainRunner]. | 10 // [args] is passed to [dartMainRunner]. |
| (...skipping 12754 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 12765 if (t1 >= $length) | 12765 if (t1 >= $length) |
| 12766 return string; | 12766 return string; |
| 12767 for (t1 = $length - string.length, t2 = string, i = 0; i < t1; ++i) | 12767 for (t1 = $length - string.length, t2 = string, i = 0; i < t1; ++i) |
| 12768 t2 += " "; | 12768 t2 += " "; |
| 12769 return t2.charCodeAt(0) == 0 ? t2 : t2; | 12769 return t2.charCodeAt(0) == 0 ? t2 : t2; |
| 12770 } | 12770 } |
| 12771 }], | 12771 }], |
| 12772 ["test.multi_channel", "package:test/src/util/multi_channel.dart", , V, { | 12772 ["test.multi_channel", "package:test/src/util/multi_channel.dart", , V, { |
| 12773 "^": "", | 12773 "^": "", |
| 12774 _MultiChannel: { | 12774 _MultiChannel: { |
| 12775 "^": "StreamChannelMixin;_innerStream,_innerSink,_innerStreamSubscription,_s
treamController,_sinkController,_streamControllers,_sinkControllers,_nextId", | 12775 "^": "StreamChannelMixin;_innerStream,_innerSink,_innerStreamSubscription,_c
losed,_streamController,_sinkController,_streamControllers,_sinkControllers,_nex
tId", |
| 12776 virtualChannel$1: function(id) { | 12776 virtualChannel$1: function(id) { |
| 12777 var t1, t2, inputId, t3, streamController, sinkController; | 12777 var t1, t2, inputId, t3, streamController, sinkController; |
| 12778 t1 = {}; | 12778 t1 = {}; |
| 12779 if (this._innerStream == null) | 12779 if (this._innerStream == null) |
| 12780 throw H.wrapException(P.StateError$("The underlying channel is closed.")
); | 12780 throw H.wrapException(P.StateError$("The underlying channel is closed.")
); |
| 12781 t1._captured_inputId_0 = null; | 12781 t1._captured_inputId_0 = null; |
| 12782 t1._captured_outputId_1 = null; | 12782 t1._captured_outputId_1 = null; |
| 12783 if (id != null) { | 12783 if (id != null) { |
| 12784 t1._captured_inputId_0 = id; | 12784 t1._captured_inputId_0 = id; |
| 12785 t1._captured_outputId_1 = H.intTypeCast(id) + 1; | 12785 t1._captured_outputId_1 = H.intTypeCast(id) + 1; |
| (...skipping 11 matching lines...) Expand all Loading... |
| 12797 throw H.wrapException(P.ArgumentError$("A virtual channel with id " + H.
S(id) + " already exists.")); | 12797 throw H.wrapException(P.ArgumentError$("A virtual channel with id " + H.
S(id) + " already exists.")); |
| 12798 streamController = P.StreamController_StreamController(null, null, null, n
ull, true, null); | 12798 streamController = P.StreamController_StreamController(null, null, null, n
ull, true, null); |
| 12799 sinkController = P.StreamController_StreamController(null, null, null, nul
l, true, null); | 12799 sinkController = P.StreamController_StreamController(null, null, null, nul
l, true, null); |
| 12800 t3.$indexSet(0, t1._captured_inputId_0, streamController); | 12800 t3.$indexSet(0, t1._captured_inputId_0, streamController); |
| 12801 this._sinkControllers.$indexSet(0, t1._captured_inputId_0, sinkController)
; | 12801 this._sinkControllers.$indexSet(0, t1._captured_inputId_0, sinkController)
; |
| 12802 H.setRuntimeTypeInfo(new P._ControllerStream(sinkController), [null]).list
en$2$onDone(new V._MultiChannel_virtualChannel_closure(t1, this), new V._MultiCh
annel_virtualChannel_closure0(t1, this)); | 12802 H.setRuntimeTypeInfo(new P._ControllerStream(sinkController), [null]).list
en$2$onDone(new V._MultiChannel_virtualChannel_closure(t1, this), new V._MultiCh
annel_virtualChannel_closure0(t1, this)); |
| 12803 return new V.VirtualChannel(this, t1._captured_outputId_1, H.setRuntimeTyp
eInfo(new P._ControllerStream(streamController), [null]), H.setRuntimeTypeInfo(n
ew P._StreamSinkWrapper(sinkController), [H.getRuntimeTypeArgument(sinkControlle
r, "_StreamController", 0)])); | 12803 return new V.VirtualChannel(this, t1._captured_outputId_1, H.setRuntimeTyp
eInfo(new P._ControllerStream(streamController), [null]), H.setRuntimeTypeInfo(n
ew P._StreamSinkWrapper(sinkController), [H.getRuntimeTypeArgument(sinkControlle
r, "_StreamController", 0)])); |
| 12804 }, | 12804 }, |
| 12805 _closeChannel$2: function(inputId, outputId) { | 12805 _closeChannel$2: function(inputId, outputId) { |
| 12806 var t1, t2; | 12806 var t1, t2; |
| 12807 if (this._closed) |
| 12808 return; |
| 12809 this._closed = true; |
| 12807 t1 = this._streamControllers; | 12810 t1 = this._streamControllers; |
| 12808 J.close$0$x(t1.remove$1(0, inputId)); | 12811 J.close$0$x(t1.remove$1(0, inputId)); |
| 12809 J.close$0$x(this._sinkControllers.remove$1(0, inputId)); | 12812 J.close$0$x(this._sinkControllers.remove$1(0, inputId)); |
| 12810 t2 = this._innerSink; | 12813 t2 = this._innerSink; |
| 12811 if (t2 == null) | 12814 if (t2 == null) |
| 12812 return; | 12815 return; |
| 12813 t2 = t2._async$_target; | 12816 t2 = t2._async$_target; |
| 12814 if (t2._state >= 4) | 12817 if (t2._state >= 4) |
| 12815 H.throwExpression(t2._badEventState$0()); | 12818 H.throwExpression(t2._badEventState$0()); |
| 12816 t2._async$_add$1([outputId]); | 12819 t2._async$_add$1([outputId]); |
| (...skipping 11 matching lines...) Expand all Loading... |
| 12828 _MultiChannel$2: function(_innerStream, _innerSink) { | 12831 _MultiChannel$2: function(_innerStream, _innerSink) { |
| 12829 var t1, t2; | 12832 var t1, t2; |
| 12830 t1 = this._streamController; | 12833 t1 = this._streamController; |
| 12831 this._streamControllers.$indexSet(0, 0, t1); | 12834 this._streamControllers.$indexSet(0, 0, t1); |
| 12832 t2 = this._sinkController; | 12835 t2 = this._sinkController; |
| 12833 this._sinkControllers.$indexSet(0, 0, t2); | 12836 this._sinkControllers.$indexSet(0, 0, t2); |
| 12834 H.setRuntimeTypeInfo(new P._ControllerStream(t2), [null]).listen$2$onDone(
new V._MultiChannel_closure(this), new V._MultiChannel_closure0(this)); | 12837 H.setRuntimeTypeInfo(new P._ControllerStream(t2), [null]).listen$2$onDone(
new V._MultiChannel_closure(this), new V._MultiChannel_closure0(this)); |
| 12835 this._innerStreamSubscription = this._innerStream.listen$3$onDone$onError(
new V._MultiChannel_closure1(this), this.get$_closeInnerChannel(), t1.get$addErr
or()); | 12838 this._innerStreamSubscription = this._innerStream.listen$3$onDone$onError(
new V._MultiChannel_closure1(this), this.get$_closeInnerChannel(), t1.get$addErr
or()); |
| 12836 }, | 12839 }, |
| 12837 static: {_MultiChannel$: function(_innerStream, _innerSink) { | 12840 static: {_MultiChannel$: function(_innerStream, _innerSink) { |
| 12838 var t1 = new V._MultiChannel(_innerStream, _innerSink, null, P.StreamCon
troller_StreamController(null, null, null, null, true, null), P.StreamController
_StreamController(null, null, null, null, true, null), P.LinkedHashMap_LinkedHas
hMap(null, null, null, P.$int, P.StreamController), P.LinkedHashMap_LinkedHashMa
p(null, null, null, P.$int, P.StreamController), 1); | 12841 var t1 = new V._MultiChannel(_innerStream, _innerSink, null, false, P.St
reamController_StreamController(null, null, null, null, true, null), P.StreamCon
troller_StreamController(null, null, null, null, true, null), P.LinkedHashMap_Li
nkedHashMap(null, null, null, P.$int, P.StreamController), P.LinkedHashMap_Linke
dHashMap(null, null, null, P.$int, P.StreamController), 1); |
| 12839 t1._MultiChannel$2(_innerStream, _innerSink); | 12842 t1._MultiChannel$2(_innerStream, _innerSink); |
| 12840 return t1; | 12843 return t1; |
| 12841 }} | 12844 }} |
| 12842 }, | 12845 }, |
| 12843 _MultiChannel_closure: { | 12846 _MultiChannel_closure: { |
| 12844 "^": "Closure:2;_multi_channel$_captured_this_0", | 12847 "^": "Closure:2;_multi_channel$_captured_this_0", |
| 12845 call$1: function(message) { | 12848 call$1: function(message) { |
| 12846 var t1 = this._multi_channel$_captured_this_0._innerSink._async$_target; | 12849 var t1 = this._multi_channel$_captured_this_0._innerSink._async$_target; |
| 12847 if (t1._state >= 4) | 12850 if (t1._state >= 4) |
| 12848 H.throwExpression(t1._badEventState$0()); | 12851 H.throwExpression(t1._badEventState$0()); |
| (...skipping 135 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 12984 if (t2 !== (t3 && C.Location_methods).get$origin(t3)) | 12987 if (t2 !== (t3 && C.Location_methods).get$origin(t3)) |
| 12985 return; | 12988 return; |
| 12986 if (!J.$eq(J.$index$asx(t1.get$data(message), "href"), J.get$src$x(this._c
aptured_iframe_0))) | 12989 if (!J.$eq(J.$index$asx(t1.get$data(message), "href"), J.get$src$x(this._c
aptured_iframe_0))) |
| 12987 return; | 12990 return; |
| 12988 message.stopPropagation(); | 12991 message.stopPropagation(); |
| 12989 t1 = this._captured_inputController_1; | 12992 t1 = this._captured_inputController_1; |
| 12990 t2 = J.$index$asx(P.convertNativeToDart_AcceptStructuredClone(message.data
, true), "data"); | 12993 t2 = J.$index$asx(P.convertNativeToDart_AcceptStructuredClone(message.data
, true), "data"); |
| 12991 if (t1._state >= 4) | 12994 if (t1._state >= 4) |
| 12992 H.throwExpression(t1._badEventState$0()); | 12995 H.throwExpression(t1._badEventState$0()); |
| 12993 t1._async$_add$1(t2); | 12996 t1._async$_add$1(t2); |
| 12994 this._captured_readyCompleter_2.complete$0(0); | 12997 t1 = this._captured_readyCompleter_2; |
| 12998 if (t1.future._state === 0) |
| 12999 t1.complete$0(0); |
| 12995 } | 13000 } |
| 12996 }, | 13001 }, |
| 12997 _connectToIframe_closure0: { | 13002 _connectToIframe_closure0: { |
| 12998 "^": "Closure:2;_captured_iframe_3,_captured_readyCompleter_4", | 13003 "^": "Closure:2;_captured_iframe_3,_captured_readyCompleter_4", |
| 12999 call$1: function(message) { | 13004 call$1: function(message) { |
| 13000 this._captured_readyCompleter_4.future.then$1(new R._connectToIframe__clos
ure(this._captured_iframe_3, message)); | 13005 this._captured_readyCompleter_4.future.then$1(new R._connectToIframe__clos
ure(this._captured_iframe_3, message)); |
| 13001 } | 13006 } |
| 13002 }, | 13007 }, |
| 13003 _connectToIframe__closure: { | 13008 _connectToIframe__closure: { |
| 13004 "^": "Closure:2;_captured_iframe_5,_captured_message_6", | 13009 "^": "Closure:2;_captured_iframe_5,_captured_message_6", |
| (...skipping 1016 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 14021 else | 14026 else |
| 14022 (function(a) { | 14027 (function(a) { |
| 14023 H.startRootIsolate(R.main$closure(), a); | 14028 H.startRootIsolate(R.main$closure(), a); |
| 14024 })([]); | 14029 })([]); |
| 14025 }); | 14030 }); |
| 14026 ; | 14031 ; |
| 14027 // END invoke [main]. | 14032 // END invoke [main]. |
| 14028 })() | 14033 })() |
| 14029 | 14034 |
| 14030 //# sourceMappingURL=host.dart.js.map | 14035 //# sourceMappingURL=host.dart.js.map |
| OLD | NEW |