| 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 |