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

Side by Side Diff: lib/runtime/dart/async.js

Issue 1095683005: fix super ctor logic (Closed) Base URL: git@github.com:dart-lang/dev_compiler.git@master
Patch Set: merge 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/runtime/dart/_js_helper.js ('k') | lib/runtime/dart/collection.js » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 var async; 1 var async;
2 (function(exports) { 2 (function(exports) {
3 'use strict'; 3 'use strict';
4 // Function _invokeErrorHandler: (Function, Object, StackTrace) → dynamic 4 // Function _invokeErrorHandler: (Function, Object, StackTrace) → dynamic
5 function _invokeErrorHandler(errorHandler, error, stackTrace) { 5 function _invokeErrorHandler(errorHandler, error, stackTrace) {
6 if (dart.is(errorHandler, ZoneBinaryCallback)) { 6 if (dart.is(errorHandler, ZoneBinaryCallback)) {
7 return dart.dcall(errorHandler, error, stackTrace); 7 return dart.dcall(errorHandler, error, stackTrace);
8 } else { 8 } else {
9 return dart.dcall(errorHandler, error); 9 return dart.dcall(errorHandler, error);
10 } 10 }
(...skipping 778 matching lines...) Expand 10 before | Expand all | Expand 10 after
789 } 789 }
790 [_onListen](subscription) {} 790 [_onListen](subscription) {}
791 } 791 }
792 return _StreamImpl; 792 return _StreamImpl;
793 }); 793 });
794 let _StreamImpl = _StreamImpl$(); 794 let _StreamImpl = _StreamImpl$();
795 let _ControllerStream$ = dart.generic(function(T) { 795 let _ControllerStream$ = dart.generic(function(T) {
796 class _ControllerStream extends _StreamImpl$(T) { 796 class _ControllerStream extends _StreamImpl$(T) {
797 _ControllerStream(controller) { 797 _ControllerStream(controller) {
798 this[_controller] = controller; 798 this[_controller] = controller;
799 super._StreamImpl();
800 } 799 }
801 [_createSubscription](onData, onError, onDone, cancelOnError) { 800 [_createSubscription](onData, onError, onDone, cancelOnError) {
802 return this[_controller][_subscribe](onData, onError, onDone, cancelOnEr ror); 801 return this[_controller][_subscribe](onData, onError, onDone, cancelOnEr ror);
803 } 802 }
804 get hashCode() { 803 get hashCode() {
805 return dart.notNull(this[_controller].hashCode) ^ 892482866; 804 return dart.notNull(this[_controller].hashCode) ^ 892482866;
806 } 805 }
807 ['=='](other) { 806 ['=='](other) {
808 if (core.identical(this, other)) 807 if (core.identical(this, other))
809 return true; 808 return true;
(...skipping 2368 matching lines...) Expand 10 before | Expand all | Expand 10 after
3178 return _EventDispatch; 3177 return _EventDispatch;
3179 }); 3178 });
3180 let _EventDispatch = _EventDispatch$(); 3179 let _EventDispatch = _EventDispatch$();
3181 let _EventGenerator = dart.typedef('_EventGenerator', () => dart.functionType( _PendingEvents, [])); 3180 let _EventGenerator = dart.typedef('_EventGenerator', () => dart.functionType( _PendingEvents, []));
3182 let _isUsed = Symbol('_isUsed'); 3181 let _isUsed = Symbol('_isUsed');
3183 let _GeneratedStreamImpl$ = dart.generic(function(T) { 3182 let _GeneratedStreamImpl$ = dart.generic(function(T) {
3184 class _GeneratedStreamImpl extends _StreamImpl$(T) { 3183 class _GeneratedStreamImpl extends _StreamImpl$(T) {
3185 _GeneratedStreamImpl(pending) { 3184 _GeneratedStreamImpl(pending) {
3186 this[_pending] = pending; 3185 this[_pending] = pending;
3187 this[_isUsed] = false; 3186 this[_isUsed] = false;
3188 super._StreamImpl();
3189 } 3187 }
3190 [_createSubscription](onData, onError, onDone, cancelOnError) { 3188 [_createSubscription](onData, onError, onDone, cancelOnError) {
3191 if (this[_isUsed]) 3189 if (this[_isUsed])
3192 throw new core.StateError("Stream has already been listened to."); 3190 throw new core.StateError("Stream has already been listened to.");
3193 this[_isUsed] = true; 3191 this[_isUsed] = true;
3194 let _ = new _BufferingStreamSubscription(onData, onError, onDone, cancel OnError); 3192 let _ = new _BufferingStreamSubscription(onData, onError, onDone, cancel OnError);
3195 _[_setPendingEvents](this[_pending]()); 3193 _[_setPendingEvents](this[_pending]());
3196 return _; 3194 return _;
3197 } 3195 }
3198 } 3196 }
(...skipping 2053 matching lines...) Expand 10 before | Expand all | Expand 10 after
5252 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; 5250 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler;
5253 exports.CreateTimerHandler = CreateTimerHandler; 5251 exports.CreateTimerHandler = CreateTimerHandler;
5254 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; 5252 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler;
5255 exports.PrintHandler = PrintHandler; 5253 exports.PrintHandler = PrintHandler;
5256 exports.ForkHandler = ForkHandler; 5254 exports.ForkHandler = ForkHandler;
5257 exports.ZoneSpecification = ZoneSpecification; 5255 exports.ZoneSpecification = ZoneSpecification;
5258 exports.ZoneDelegate = ZoneDelegate; 5256 exports.ZoneDelegate = ZoneDelegate;
5259 exports.Zone = Zone; 5257 exports.Zone = Zone;
5260 exports.runZoned = runZoned; 5258 exports.runZoned = runZoned;
5261 })(async || (async = {})); 5259 })(async || (async = {}));
OLDNEW
« no previous file with comments | « lib/runtime/dart/_js_helper.js ('k') | lib/runtime/dart/collection.js » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698