| 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(((__x8) => DEVC$RT.wrap((dynamic f(_BroadcastSubscription<T> __
u3)) { | 240 _forEachListener(((__x7) => DEVC$RT.cast(__x7, DEVC$RT.type((__t5<T> _) { |
| 241 dynamic c(_BroadcastSubscription<T> x0) => f(DEVC$RT.cast(x0, DEVC$RT.type((_Buf
feringStreamSubscription<T> _) { | |
| 242 } | 241 } |
| 243 ), DEVC$RT.type((_BroadcastSubscription<T> _) { | 242 ), DEVC$RT.type((__t3<T> _) { |
| 244 } | 243 } |
| 245 ), "CastParam", """line 372, column 24 of dart:async/broadcast_stream_controller
.dart: """, x0 is _BroadcastSubscription<T>, false)); | 244 ), "InferableClosure", """line 372, column 24 of dart:async/broadcast_stream_con
troller.dart: """, __x7 is __t3<T>, false))((_BroadcastSubscription<T> subscript
ion) { |
| 246 return f == null ? null : c; | |
| 247 } | |
| 248 , __x8, DEVC$RT.type((__t6<T> _) { | |
| 249 } | |
| 250 ), DEVC$RT.type((__t4<T> _) { | |
| 251 } | |
| 252 ), "WrapLiteral", """line 372, column 24 of dart:async/broadcast_stream_controll
er.dart: """, __x8 is __t4<T>))((_BroadcastSubscription<T> subscription) { | |
| 253 subscription._close(); | 245 subscription._close(); |
| 254 } | 246 } |
| 255 )); | 247 )); |
| 256 } | 248 } |
| 257 else { | 249 else { |
| 258 assert (_doneFuture != null); assert (_doneFuture._mayComplete); _doneFuture._as
yncComplete(null); | 250 assert (_doneFuture != null); assert (_doneFuture._mayComplete); _doneFuture._as
yncComplete(null); |
| 259 } | 251 } |
| 260 } | 252 } |
| 261 } | 253 } |
| 262 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... |
| 351 } | 343 } |
| 352 void _resume(_) { | 344 void _resume(_) { |
| 353 if (_pauseCount > 0) _pauseCount--; | 345 if (_pauseCount > 0) _pauseCount--; |
| 354 } | 346 } |
| 355 Future cancel() { | 347 Future cancel() { |
| 356 return new _Future.immediate(null); | 348 return new _Future.immediate(null); |
| 357 } | 349 } |
| 358 bool get isPaused => _pauseCount > 0; | 350 bool get isPaused => _pauseCount > 0; |
| 359 Future asFuture([Object value]) => new _Future(); | 351 Future asFuture([Object value]) => new _Future(); |
| 360 } | 352 } |
| 361 typedef void __t4<T>(_BufferingStreamSubscription<T> __u5); | 353 typedef void __t3<T>(_BufferingStreamSubscription<T> __u4); |
| 362 typedef dynamic __t6<T>(_BroadcastSubscription<T> __u7); | 354 typedef dynamic __t5<T>(_BroadcastSubscription<T> __u6); |
| OLD | NEW |