OLD | NEW |
1 part of dart.async; | 1 part of dart.async; |
2 class _BroadcastStream<T> extends _ControllerStream<T> {_BroadcastStream(_Strea
mControllerLifecycle controller) : super(DEVC$RT.cast(controller, DEVC$RT.type((
_StreamControllerLifecycle<dynamic> _) { | 2 class _BroadcastStream<T> extends _ControllerStream<T> {_BroadcastStream(_Strea
mControllerLifecycle controller) : super(DEVC$RT.cast(controller, DEVC$RT.type((
_StreamControllerLifecycle<dynamic> _) { |
3 } | 3 } |
4 ), DEVC$RT.type((_StreamControllerLifecycle<T> _) { | 4 ), DEVC$RT.type((_StreamControllerLifecycle<T> _) { |
5 } | 5 } |
6 ), "CompositeCast", """line 8, column 67 of dart:async/broadcast_stream_controll
er.dart: """, controller is _StreamControllerLifecycle<T>, false)); | 6 ), "CompositeCast", """line 8, column 67 of dart:async/broadcast_stream_controll
er.dart: """, controller is _StreamControllerLifecycle<T>, false)); |
7 bool get isBroadcast => true; | 7 bool get isBroadcast => true; |
8 } | 8 } |
9 abstract class _BroadcastSubscriptionLink {_BroadcastSubscriptionLink _next; | 9 abstract class _BroadcastSubscriptionLink {_BroadcastSubscriptionLink _next; |
10 _BroadcastSubscriptionLink _previous; | 10 _BroadcastSubscriptionLink _previous; |
(...skipping 219 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
230 ); | 230 ); |
231 } | 231 } |
232 void _sendError(Object error, StackTrace stackTrace) { | 232 void _sendError(Object error, StackTrace stackTrace) { |
233 if (_isEmpty) return; _forEachListener((_BufferingStreamSubscription<T> subscrip
tion) { | 233 if (_isEmpty) return; _forEachListener((_BufferingStreamSubscription<T> subscrip
tion) { |
234 subscription._addError(error, stackTrace); | 234 subscription._addError(error, stackTrace); |
235 } | 235 } |
236 ); | 236 ); |
237 } | 237 } |
238 void _sendDone() { | 238 void _sendDone() { |
239 if (!_isEmpty) { | 239 if (!_isEmpty) { |
240 _forEachListener(((__x7) => DEVC$RT.cast(__x7, DEVC$RT.type((__t5<T> _) { | 240 _forEachListener(((__x7) => DEVC$RT.cast(__x7, DEVC$RT.type((__CastType5<T> _) { |
241 } | 241 } |
242 ), DEVC$RT.type((__t3<T> _) { | 242 ), DEVC$RT.type((__CastType3<T> _) { |
243 } | 243 } |
244 ), "InferableClosure", """line 372, column 24 of dart:async/broadcast_stream_con
troller.dart: """, __x7 is __t3<T>, false))((_BroadcastSubscription<T> subscript
ion) { | 244 ), "InferableClosure", """line 372, column 24 of dart:async/broadcast_stream_con
troller.dart: """, __x7 is __CastType3<T>, false))((_BroadcastSubscription<T> su
bscription) { |
245 subscription._close(); | 245 subscription._close(); |
246 } | 246 } |
247 )); | 247 )); |
248 } | 248 } |
249 else { | 249 else { |
250 assert (_doneFuture != null); assert (_doneFuture._mayComplete); _doneFuture._as
yncComplete(null); | 250 assert (_doneFuture != null); assert (_doneFuture._mayComplete); _doneFuture._as
yncComplete(null); |
251 } | 251 } |
252 } | 252 } |
253 } | 253 } |
254 class _AsyncBroadcastStreamController<T> extends _BroadcastStreamController<T>
{_AsyncBroadcastStreamController(void onListen(), void onCancel()) : super(onLis
ten, onCancel); | 254 class _AsyncBroadcastStreamController<T> extends _BroadcastStreamController<T>
{_AsyncBroadcastStreamController(void onListen(), void onCancel()) : super(onLis
ten, onCancel); |
(...skipping 88 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
343 } | 343 } |
344 void _resume(_) { | 344 void _resume(_) { |
345 if (_pauseCount > 0) _pauseCount--; | 345 if (_pauseCount > 0) _pauseCount--; |
346 } | 346 } |
347 Future cancel() { | 347 Future cancel() { |
348 return new _Future.immediate(null); | 348 return new _Future.immediate(null); |
349 } | 349 } |
350 bool get isPaused => _pauseCount > 0; | 350 bool get isPaused => _pauseCount > 0; |
351 Future asFuture([Object value]) => new _Future(); | 351 Future asFuture([Object value]) => new _Future(); |
352 } | 352 } |
353 typedef void __t3<T>(_BufferingStreamSubscription<T> __u4); | 353 typedef void __CastType3<T>(_BufferingStreamSubscription<T> __u4); |
354 typedef dynamic __t5<T>(_BroadcastSubscription<T> __u6); | 354 typedef dynamic __CastType5<T>(_BroadcastSubscription<T> __u6); |
OLD | NEW |