| OLD | NEW |
| 1 part of dart.async; | 1 part of dart.async; |
| 2 class _BroadcastStream<T> extends _ControllerStream<T> {_BroadcastStream(_Strea
mControllerLifecycle controller) : super(DDC$RT.cast(controller, DDC$RT.type((_S
treamControllerLifecycle<dynamic> _) { | 2 class _BroadcastStream<T> extends _ControllerStream<T> {_BroadcastStream(_Strea
mControllerLifecycle controller) : super(DDC$RT.cast(controller, DDC$RT.type((_S
treamControllerLifecycle<dynamic> _) { |
| 3 } | 3 } |
| 4 ), DDC$RT.type((_StreamControllerLifecycle<T> _) { | 4 ), DDC$RT.type((_StreamControllerLifecycle<T> _) { |
| 5 } | 5 } |
| 6 ), "CastDynamic", """line 8, column 67 of dart:async/broadcast_stream_controller
.dart: """, controller is _StreamControllerLifecycle<T>, false)); | 6 ), "CastDynamic", """line 8, column 67 of dart:async/broadcast_stream_controller
.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 247 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 258 } | 258 } |
| 259 )); | 259 )); |
| 260 } | 260 } |
| 261 else { | 261 else { |
| 262 assert (_doneFuture != null); assert (_doneFuture._mayComplete); _doneFuture._as
yncComplete(null); | 262 assert (_doneFuture != null); assert (_doneFuture._mayComplete); _doneFuture._as
yncComplete(null); |
| 263 } | 263 } |
| 264 } | 264 } |
| 265 } | 265 } |
| 266 class _AsyncBroadcastStreamController<T> extends _BroadcastStreamController<T>
{_AsyncBroadcastStreamController(void onListen(), void onCancel()) : super(onLis
ten, onCancel); | 266 class _AsyncBroadcastStreamController<T> extends _BroadcastStreamController<T>
{_AsyncBroadcastStreamController(void onListen(), void onCancel()) : super(onLis
ten, onCancel); |
| 267 void _sendData(T data) { | 267 void _sendData(T data) { |
| 268 for (_BroadcastSubscriptionLink link = _next; | 268 for (_BroadcastSubscriptionLink link = _next; !identical(link, this); link = lin
k._next) { |
| 269 !identical(link, this); | |
| 270 link = link._next) { | |
| 271 _BroadcastSubscription<T> subscription = DDC$RT.cast(link, _BroadcastSubscriptio
nLink, DDC$RT.type((_BroadcastSubscription<T> _) { | 269 _BroadcastSubscription<T> subscription = DDC$RT.cast(link, _BroadcastSubscriptio
nLink, DDC$RT.type((_BroadcastSubscription<T> _) { |
| 272 } | 270 } |
| 273 ), "CastGeneral", """line 393, column 48 of dart:async/broadcast_stream_controll
er.dart: """, link is _BroadcastSubscription<T>, false); | 271 ), "CastGeneral", """line 393, column 48 of dart:async/broadcast_stream_controll
er.dart: """, link is _BroadcastSubscription<T>, false); |
| 274 subscription._addPending(new _DelayedData(data)); | 272 subscription._addPending(new _DelayedData(data)); |
| 275 } | 273 } |
| 276 } | 274 } |
| 277 void _sendError(Object error, StackTrace stackTrace) { | 275 void _sendError(Object error, StackTrace stackTrace) { |
| 278 for (_BroadcastSubscriptionLink link = _next; | 276 for (_BroadcastSubscriptionLink link = _next; !identical(link, this); link = lin
k._next) { |
| 279 !identical(link, this); | |
| 280 link = link._next) { | |
| 281 _BroadcastSubscription<T> subscription = DDC$RT.cast(link, _BroadcastSubscriptio
nLink, DDC$RT.type((_BroadcastSubscription<T> _) { | 277 _BroadcastSubscription<T> subscription = DDC$RT.cast(link, _BroadcastSubscriptio
nLink, DDC$RT.type((_BroadcastSubscription<T> _) { |
| 282 } | 278 } |
| 283 ), "CastGeneral", """line 402, column 48 of dart:async/broadcast_stream_controll
er.dart: """, link is _BroadcastSubscription<T>, false); | 279 ), "CastGeneral", """line 402, column 48 of dart:async/broadcast_stream_controll
er.dart: """, link is _BroadcastSubscription<T>, false); |
| 284 subscription._addPending(new _DelayedError(error, stackTrace)); | 280 subscription._addPending(new _DelayedError(error, stackTrace)); |
| 285 } | 281 } |
| 286 } | 282 } |
| 287 void _sendDone() { | 283 void _sendDone() { |
| 288 if (!_isEmpty) { | 284 if (!_isEmpty) { |
| 289 for (_BroadcastSubscriptionLink link = _next; | 285 for (_BroadcastSubscriptionLink link = _next; !identical(link, this); link = lin
k._next) { |
| 290 !identical(link, this); | |
| 291 link = link._next) { | |
| 292 _BroadcastSubscription<T> subscription = DDC$RT.cast(link, _BroadcastSubscriptio
nLink, DDC$RT.type((_BroadcastSubscription<T> _) { | 286 _BroadcastSubscription<T> subscription = DDC$RT.cast(link, _BroadcastSubscriptio
nLink, DDC$RT.type((_BroadcastSubscription<T> _) { |
| 293 } | 287 } |
| 294 ), "CastGeneral", """line 412, column 50 of dart:async/broadcast_stream_controll
er.dart: """, link is _BroadcastSubscription<T>, false); | 288 ), "CastGeneral", """line 412, column 50 of dart:async/broadcast_stream_controll
er.dart: """, link is _BroadcastSubscription<T>, false); |
| 295 subscription._addPending(const _DelayedDone()); | 289 subscription._addPending(const _DelayedDone()); |
| 296 } | 290 } |
| 297 } | 291 } |
| 298 else { | 292 else { |
| 299 assert (_doneFuture != null); assert (_doneFuture._mayComplete); _doneFuture._as
yncComplete(null); | 293 assert (_doneFuture != null); assert (_doneFuture._mayComplete); _doneFuture._as
yncComplete(null); |
| 300 } | 294 } |
| 301 } | 295 } |
| (...skipping 61 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 363 if (_pauseCount > 0) _pauseCount--; | 357 if (_pauseCount > 0) _pauseCount--; |
| 364 } | 358 } |
| 365 Future cancel() { | 359 Future cancel() { |
| 366 return new _Future.immediate(null); | 360 return new _Future.immediate(null); |
| 367 } | 361 } |
| 368 bool get isPaused => _pauseCount > 0; | 362 bool get isPaused => _pauseCount > 0; |
| 369 Future asFuture([Object value]) => new _Future(); | 363 Future asFuture([Object value]) => new _Future(); |
| 370 } | 364 } |
| 371 typedef void __t5<T>(_BufferingStreamSubscription<T> __u6); | 365 typedef void __t5<T>(_BufferingStreamSubscription<T> __u6); |
| 372 typedef dynamic __t7<T>(_BroadcastSubscription<T> __u8); | 366 typedef dynamic __t7<T>(_BroadcastSubscription<T> __u8); |
| OLD | NEW |