| OLD | NEW |
| 1 part of dart.async; | 1 part of dart.async; |
| 2 abstract class StreamController<T> implements StreamSink<T> {Stream<T> get stre
am; | 2 abstract class StreamController<T> implements StreamSink<T> {Stream<T> get stre
am; |
| 3 factory StreamController({ | 3 factory StreamController({ |
| 4 void onListen(), void onPause(), void onResume(), onCancel(), bool sync : fals
e} | 4 void onListen(), void onPause(), void onResume(), onCancel(), bool sync : fals
e} |
| 5 ) { | 5 ) { |
| 6 if (onListen == null && onPause == null && onResume == null && onCancel == nul
l) { | 6 if (onListen == null && onPause == null && onResume == null && onCancel == nul
l) { |
| 7 return ((__x47) => DEVC$RT.cast(__x47, DEVC$RT.type((_StreamController<dynam
ic> _) { | 7 return ((__x42) => DEVC$RT.cast(__x42, DEVC$RT.type((_StreamController<dynam
ic> _) { |
| 8 } | 8 } |
| 9 ), DEVC$RT.type((StreamController<T> _) { | 9 ), DEVC$RT.type((StreamController<T> _) { |
| 10 } | 10 } |
| 11 ), "CompositeCast", """line 83, column 14 of dart:async/stream_controller.da
rt: """, __x47 is StreamController<T>, false))(sync ? new _NoCallbackSyncStreamC
ontroller() : new _NoCallbackAsyncStreamController()); | 11 ), "CompositeCast", """line 83, column 14 of dart:async/stream_controller.da
rt: """, __x42 is StreamController<T>, false))(sync ? new _NoCallbackSyncStreamC
ontroller() : new _NoCallbackAsyncStreamController()); |
| 12 } | 12 } |
| 13 return sync ? new _SyncStreamController<T>(onListen, onPause, onResume, onCan
cel) : new _AsyncStreamController<T>(onListen, onPause, onResume, onCancel); | 13 return sync ? new _SyncStreamController<T>(onListen, onPause, onResume, onCan
cel) : new _AsyncStreamController<T>(onListen, onPause, onResume, onCancel); |
| 14 } | 14 } |
| 15 factory StreamController.broadcast({ | 15 factory StreamController.broadcast({ |
| 16 void onListen(), void onCancel(), bool sync : false} | 16 void onListen(), void onCancel(), bool sync : false} |
| 17 ) { | 17 ) { |
| 18 return sync ? new _SyncBroadcastStreamController<T>(onListen, onCancel) : new
_AsyncBroadcastStreamController<T>(onListen, onCancel); | 18 return sync ? new _SyncBroadcastStreamController<T>(onListen, onCancel) : new
_AsyncBroadcastStreamController<T>(onListen, onCancel); |
| 19 } | 19 } |
| 20 StreamSink<T> get sink; | 20 StreamSink<T> get sink; |
| 21 bool get isClosed; | 21 bool get isClosed; |
| (...skipping 179 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 201 _StreamControllerAddStreamState addState = DEVC$RT.cast(_varData, dynamic, DEVC$
RT.type((_StreamControllerAddStreamState<dynamic> _) { | 201 _StreamControllerAddStreamState addState = DEVC$RT.cast(_varData, dynamic, DEVC$
RT.type((_StreamControllerAddStreamState<dynamic> _) { |
| 202 } | 202 } |
| 203 ), "DynamicCast", """line 530, column 50 of dart:async/stream_controller.dart: "
"", _varData is _StreamControllerAddStreamState<dynamic>, true); | 203 ), "DynamicCast", """line 530, column 50 of dart:async/stream_controller.dart: "
"", _varData is _StreamControllerAddStreamState<dynamic>, true); |
| 204 result = addState.cancel(); | 204 result = addState.cancel(); |
| 205 } | 205 } |
| 206 _varData = null; | 206 _varData = null; |
| 207 _state = (_state & ~(_STATE_SUBSCRIBED | _STATE_ADDSTREAM)) | _STATE_CANCELED; | 207 _state = (_state & ~(_STATE_SUBSCRIBED | _STATE_ADDSTREAM)) | _STATE_CANCELED; |
| 208 if (_onCancel != null) { | 208 if (_onCancel != null) { |
| 209 if (result == null) { | 209 if (result == null) { |
| 210 try { | 210 try { |
| 211 result = ((__x48) => DEVC$RT.cast(__x48, dynamic, DEVC$RT.type((Future<dynam
ic> _) { | 211 result = ((__x43) => DEVC$RT.cast(__x43, dynamic, DEVC$RT.type((Future<dynam
ic> _) { |
| 212 } | 212 } |
| 213 ), "DynamicCast", """line 542, column 20 of dart:async/stream_controller.dar
t: """, __x48 is Future<dynamic>, true))(_onCancel()); | 213 ), "DynamicCast", """line 542, column 20 of dart:async/stream_controller.dar
t: """, __x43 is Future<dynamic>, true))(_onCancel()); |
| 214 } | 214 } |
| 215 catch (e, s) { | 215 catch (e, s) { |
| 216 result = new _Future().._asyncCompleteError(e, s); | 216 result = new _Future().._asyncCompleteError(e, s); |
| 217 } | 217 } |
| 218 } | 218 } |
| 219 else { | 219 else { |
| 220 result = result.whenComplete(_onCancel); | 220 result = result.whenComplete(_onCancel); |
| 221 } | 221 } |
| 222 } | 222 } |
| 223 void complete() { | 223 void complete() { |
| (...skipping 115 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 339 _target.addError(error, stackTrace); | 339 _target.addError(error, stackTrace); |
| 340 } | 340 } |
| 341 Future close() => _target.close(); | 341 Future close() => _target.close(); |
| 342 Future addStream(Stream<T> source, { | 342 Future addStream(Stream<T> source, { |
| 343 bool cancelOnError : true} | 343 bool cancelOnError : true} |
| 344 ) => _target.addStream(source, cancelOnError: cancelOnError); | 344 ) => _target.addStream(source, cancelOnError: cancelOnError); |
| 345 Future get done => _target.done; | 345 Future get done => _target.done; |
| 346 } | 346 } |
| 347 class _AddStreamState<T> {final _Future addStreamFuture; | 347 class _AddStreamState<T> {final _Future addStreamFuture; |
| 348 final StreamSubscription addSubscription; | 348 final StreamSubscription addSubscription; |
| 349 _AddStreamState(_EventSink<T> controller, Stream source, bool cancelOnError) :
addStreamFuture = new _Future(), addSubscription = source.listen(controller._add
, onError: cancelOnError ? ((__x49) => DEVC$RT.cast(__x49, dynamic, Function, "D
ynamicCast", """line 747, column 48 of dart:async/stream_controller.dart: """, _
_x49 is Function, true))(makeErrorHandler(controller)) : controller._addError, o
nDone: controller._close, cancelOnError: cancelOnError); | 349 _AddStreamState(_EventSink<T> controller, Stream source, bool cancelOnError) :
addStreamFuture = new _Future(), addSubscription = source.listen(controller._add
, onError: cancelOnError ? ((__x44) => DEVC$RT.cast(__x44, dynamic, Function, "D
ynamicCast", """line 747, column 48 of dart:async/stream_controller.dart: """, _
_x44 is Function, true))(makeErrorHandler(controller)) : controller._addError, o
nDone: controller._close, cancelOnError: cancelOnError); |
| 350 static makeErrorHandler(_EventSink controller) => (e, StackTrace s) { | 350 static makeErrorHandler(_EventSink controller) => (e, StackTrace s) { |
| 351 controller._addError(e, s); | 351 controller._addError(e, s); |
| 352 controller._close(); | 352 controller._close(); |
| 353 } | 353 } |
| 354 ; | 354 ; |
| 355 void pause() { | 355 void pause() { |
| 356 addSubscription.pause(); | 356 addSubscription.pause(); |
| 357 } | 357 } |
| 358 void resume() { | 358 void resume() { |
| 359 addSubscription.resume(); | 359 addSubscription.resume(); |
| (...skipping 17 matching lines...) Expand all Loading... |
| 377 _StreamControllerAddStreamState(_StreamController controller, this.varData, Str
eam source, bool cancelOnError) : super(DEVC$RT.cast(controller, DEVC$RT.type((_
StreamController<dynamic> _) { | 377 _StreamControllerAddStreamState(_StreamController controller, this.varData, Str
eam source, bool cancelOnError) : super(DEVC$RT.cast(controller, DEVC$RT.type((_
StreamController<dynamic> _) { |
| 378 } | 378 } |
| 379 ), DEVC$RT.type((_EventSink<T> _) { | 379 ), DEVC$RT.type((_EventSink<T> _) { |
| 380 } | 380 } |
| 381 ), "CompositeCast", """line 798, column 15 of dart:async/stream_controller.dart:
""", controller is _EventSink<T>, false), source, cancelOnError) { | 381 ), "CompositeCast", """line 798, column 15 of dart:async/stream_controller.dart:
""", controller is _EventSink<T>, false), source, cancelOnError) { |
| 382 if (controller.isPaused) { | 382 if (controller.isPaused) { |
| 383 addSubscription.pause(); | 383 addSubscription.pause(); |
| 384 } | 384 } |
| 385 } | 385 } |
| 386 } | 386 } |
| OLD | NEW |