Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(281)

Side by Side Diff: lib/src/runner/browser/static/host.dart.js

Issue 1087693002: Don't double-complete in host.dart. (Closed) Base URL: git@github.com:dart-lang/test@master
Patch Set: Created 5 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « lib/src/runner/browser/static/host.dart ('k') | lib/src/runner/browser/static/host.dart.js.map » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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
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
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
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
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
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
OLDNEW
« no previous file with comments | « lib/src/runner/browser/static/host.dart ('k') | lib/src/runner/browser/static/host.dart.js.map » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698