OLD | NEW |
1 dart_library.library('dart/async', null, /* Imports */[ | 1 dart_library.library('dart/async', null, /* Imports */[ |
2 "dart/_runtime", | 2 "dart/_runtime", |
3 'dart/core', | 3 'dart/core', |
4 'dart/_internal', | 4 'dart/_internal', |
5 'dart/collection' | 5 'dart/collection' |
6 ], /* Lazy imports */[ | 6 ], /* Lazy imports */[ |
7 'dart/_isolate_helper' | 7 'dart/_isolate_helper' |
8 ], function(exports, dart, core, _internal, collection, _isolate_helper) { | 8 ], function(exports, dart, core, _internal, collection, _isolate_helper) { |
9 'use strict'; | 9 'use strict'; |
10 let dartx = dart.dartx; | 10 let dartx = dart.dartx; |
(...skipping 1242 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1253 let _removeAfterFiring = Symbol('_removeAfterFiring'); | 1253 let _removeAfterFiring = Symbol('_removeAfterFiring'); |
1254 let _BroadcastSubscription$ = dart.generic(function(T) { | 1254 let _BroadcastSubscription$ = dart.generic(function(T) { |
1255 class _BroadcastSubscription extends _ControllerSubscription$(T) { | 1255 class _BroadcastSubscription extends _ControllerSubscription$(T) { |
1256 _BroadcastSubscription(controller, onData, onError, onDone, cancelOnError)
{ | 1256 _BroadcastSubscription(controller, onData, onError, onDone, cancelOnError)
{ |
1257 this[_eventState] = null; | 1257 this[_eventState] = null; |
1258 this[_next] = null; | 1258 this[_next] = null; |
1259 this[_previous] = null; | 1259 this[_previous] = null; |
1260 super._ControllerSubscription(dart.as(controller, _StreamControllerLifec
ycle$(T)), onData, onError, onDone, cancelOnError); | 1260 super._ControllerSubscription(dart.as(controller, _StreamControllerLifec
ycle$(T)), onData, onError, onDone, cancelOnError); |
1261 this[_next] = this[_previous] = this; | 1261 this[_next] = this[_previous] = this; |
1262 } | 1262 } |
1263 get [_controller]() { | |
1264 return dart.as(super[_controller], _BroadcastStreamController$(T)); | |
1265 } | |
1266 [_expectsEvent](eventId) { | 1263 [_expectsEvent](eventId) { |
1267 return (dart.notNull(this[_eventState]) & dart.notNull(_BroadcastSubscri
ption$()._STATE_EVENT_ID)) == eventId; | 1264 return (dart.notNull(this[_eventState]) & dart.notNull(_BroadcastSubscri
ption$()._STATE_EVENT_ID)) == eventId; |
1268 } | 1265 } |
1269 [_toggleEventId]() { | 1266 [_toggleEventId]() { |
1270 this[_eventState] = dart.notNull(this[_eventState]) ^ dart.notNull(_Broa
dcastSubscription$()._STATE_EVENT_ID); | 1267 this[_eventState] = dart.notNull(this[_eventState]) ^ dart.notNull(_Broa
dcastSubscription$()._STATE_EVENT_ID); |
1271 } | 1268 } |
1272 get [_isFiring]() { | 1269 get [_isFiring]() { |
1273 return (dart.notNull(this[_eventState]) & dart.notNull(_BroadcastSubscri
ption$()._STATE_FIRING)) != 0; | 1270 return (dart.notNull(this[_eventState]) & dart.notNull(_BroadcastSubscri
ption$()._STATE_FIRING)) != 0; |
1274 } | 1271 } |
1275 [_setRemoveAfterFiring]() { | 1272 [_setRemoveAfterFiring]() { |
(...skipping 4638 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
5914 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; | 5911 exports.ScheduleMicrotaskHandler = ScheduleMicrotaskHandler; |
5915 exports.CreateTimerHandler = CreateTimerHandler; | 5912 exports.CreateTimerHandler = CreateTimerHandler; |
5916 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; | 5913 exports.CreatePeriodicTimerHandler = CreatePeriodicTimerHandler; |
5917 exports.PrintHandler = PrintHandler; | 5914 exports.PrintHandler = PrintHandler; |
5918 exports.ForkHandler = ForkHandler; | 5915 exports.ForkHandler = ForkHandler; |
5919 exports.ZoneSpecification = ZoneSpecification; | 5916 exports.ZoneSpecification = ZoneSpecification; |
5920 exports.ZoneDelegate = ZoneDelegate; | 5917 exports.ZoneDelegate = ZoneDelegate; |
5921 exports.Zone = Zone; | 5918 exports.Zone = Zone; |
5922 exports.runZoned = runZoned; | 5919 exports.runZoned = runZoned; |
5923 }); | 5920 }); |
OLD | NEW |