OLD | NEW |
1 var async = dart.defineLibrary(async, {}); | 1 var async = dart.defineLibrary(async, {}); |
2 var core = dart.import(core); | 2 var core = dart.import(core); |
3 var _internal = dart.import(_internal); | 3 var _internal = dart.import(_internal); |
4 var _js_helper = dart.lazyImport(_js_helper); | 4 var _js_helper = dart.lazyImport(_js_helper); |
5 var _isolate_helper = dart.lazyImport(_isolate_helper); | 5 var _isolate_helper = dart.lazyImport(_isolate_helper); |
6 var collection = dart.import(collection); | 6 var collection = dart.import(collection); |
7 (function(exports, core, _internal, _js_helper, _isolate_helper, collection) { | 7 (function(exports, core, _internal, _js_helper, _isolate_helper, collection) { |
8 'use strict'; | 8 'use strict'; |
9 function _invokeErrorHandler(errorHandler, error, stackTrace) { | 9 function _invokeErrorHandler(errorHandler, error, stackTrace) { |
10 if (dart.is(errorHandler, ZoneBinaryCallback)) { | 10 if (dart.is(errorHandler, ZoneBinaryCallback)) { |
(...skipping 1378 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1389 if (core.identical(this[_next], this[_previous])) { | 1389 if (core.identical(this[_next], this[_previous])) { |
1390 _runGuarded(this[_onListen]); | 1390 _runGuarded(this[_onListen]); |
1391 } | 1391 } |
1392 return dart.as(subscription, StreamSubscription$(T)); | 1392 return dart.as(subscription, StreamSubscription$(T)); |
1393 } | 1393 } |
1394 [_recordCancel](subscription) { | 1394 [_recordCancel](subscription) { |
1395 dart.as(subscription, StreamSubscription$(T)); | 1395 dart.as(subscription, StreamSubscription$(T)); |
1396 if (core.identical(subscription[_next], subscription)) | 1396 if (core.identical(subscription[_next], subscription)) |
1397 return null; | 1397 return null; |
1398 dart.assert(!dart.notNull(core.identical(subscription[_next], subscripti
on))); | 1398 dart.assert(!dart.notNull(core.identical(subscription[_next], subscripti
on))); |
1399 if (subscription[_isFiring]) { | 1399 if (dart.as(subscription[_isFiring], core.bool)) { |
1400 dart.dcall(subscription[_setRemoveAfterFiring]); | 1400 dart.dcall(subscription[_setRemoveAfterFiring]); |
1401 } else { | 1401 } else { |
1402 dart.assert(!dart.notNull(core.identical(subscription[_next], subscrip
tion))); | 1402 dart.assert(!dart.notNull(core.identical(subscription[_next], subscrip
tion))); |
1403 this[_removeListener](dart.as(subscription, _BroadcastSubscription$(T)
)); | 1403 this[_removeListener](dart.as(subscription, _BroadcastSubscription$(T)
)); |
1404 if (!dart.notNull(this[_isFiring]) && dart.notNull(this[_isEmpty])) { | 1404 if (!dart.notNull(this[_isFiring]) && dart.notNull(this[_isEmpty])) { |
1405 this[_callOnCancel](); | 1405 this[_callOnCancel](); |
1406 } | 1406 } |
1407 } | 1407 } |
1408 return null; | 1408 return null; |
1409 } | 1409 } |
(...skipping 4491 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
5901 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; | 5901 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; |
5902 exports.CreateTimerHandler = CreateTimerHandler; | 5902 exports.CreateTimerHandler = CreateTimerHandler; |
5903 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; | 5903 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; |
5904 exports.PrintHandler = PrintHandler; | 5904 exports.PrintHandler = PrintHandler; |
5905 exports.ForkHandler = ForkHandler; | 5905 exports.ForkHandler = ForkHandler; |
5906 exports.ZoneSpecification = ZoneSpecification; | 5906 exports.ZoneSpecification = ZoneSpecification; |
5907 exports.ZoneDelegate = ZoneDelegate; | 5907 exports.ZoneDelegate = ZoneDelegate; |
5908 exports.Zone = Zone; | 5908 exports.Zone = Zone; |
5909 exports.runZoned = runZoned; | 5909 exports.runZoned = runZoned; |
5910 })(async, core, _internal, _js_helper, _isolate_helper, collection); | 5910 })(async, core, _internal, _js_helper, _isolate_helper, collection); |
OLD | NEW |