Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(420)

Issues Search
    My Issues | Starred     Open | Closed | All

Unified Diff: test/dart_codegen/expect/async/broadcast_stream_controller.dart

Issue 963593002: Disable formatting and add new-lines to make tests faster. (Closed) Base URL: git@github.com:dart-lang/dev_compiler.git@master
Patch Set: Created 5 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« test/dart_codegen/expect/_internal/iterable.dart ('K') | « test/dart_codegen/expect/async/async_error.dart ('k') | test/dart_codegen/expect/async/deferred_load.dart » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: test/dart_codegen/expect/async/broadcast_stream_controller.dart
diff --git a/test/dart_codegen/expect/async/broadcast_stream_controller.dart b/test/dart_codegen/expect/async/broadcast_stream_controller.dart
index ff1d2df57e8212b717dab86ef25d24879c568253..096b076ce0516f8018fef92c83fe81df7fa57007 100644
--- a/test/dart_codegen/expect/async/broadcast_stream_controller.dart
+++ b/test/dart_codegen/expect/async/broadcast_stream_controller.dart
@@ -1,412 +1,372 @@
part of dart.async;
-
-class _BroadcastStream<T> extends _ControllerStream<T> {
- _BroadcastStream(_StreamControllerLifecycle controller) : super(DDC$RT.cast(
- controller, DDC$RT.type((_StreamControllerLifecycle<dynamic> _) {}),
- DDC$RT.type((_StreamControllerLifecycle<T> _) {}), "CastDynamic",
- """line 8, column 67 of dart:async/broadcast_stream_controller.dart: """,
- controller is _StreamControllerLifecycle<T>, false));
- bool get isBroadcast => true;
-}
-abstract class _BroadcastSubscriptionLink {
- _BroadcastSubscriptionLink _next;
- _BroadcastSubscriptionLink _previous;
-}
-class _BroadcastSubscription<T> extends _ControllerSubscription<T>
- implements _BroadcastSubscriptionLink {
- static const int _STATE_EVENT_ID = 1;
- static const int _STATE_FIRING = 2;
- static const int _STATE_REMOVE_AFTER_FIRING = 4;
- int _eventState;
- _BroadcastSubscriptionLink _next;
- _BroadcastSubscriptionLink _previous;
- _BroadcastSubscription(_StreamControllerLifecycle controller,
- void onData(T data), Function onError, void onDone(), bool cancelOnError)
- : super(DDC$RT.cast(controller,
- DDC$RT.type((_StreamControllerLifecycle<dynamic> _) {}),
- DDC$RT.type((_StreamControllerLifecycle<T> _) {}), "CastDynamic",
- """line 36, column 15 of dart:async/broadcast_stream_controller.dart: """,
- controller is _StreamControllerLifecycle<T>,
- false), onData, onError, onDone, cancelOnError) {
- _next = _previous = this;
+ class _BroadcastStream<T> extends _ControllerStream<T> {_BroadcastStream(_StreamControllerLifecycle controller) : super(DDC$RT.cast(controller, DDC$RT.type((_StreamControllerLifecycle<dynamic> _) {
}
- _BroadcastStreamController get _controller => ((__x2) => DDC$RT.cast(__x2,
- DDC$RT.type((_StreamControllerLifecycle<T> _) {}),
- DDC$RT.type((_BroadcastStreamController<dynamic> _) {}), "CastGeneral",
- """line 40, column 49 of dart:async/broadcast_stream_controller.dart: """,
- __x2 is _BroadcastStreamController<dynamic>, true))(super._controller);
- bool _expectsEvent(int eventId) => (_eventState & _STATE_EVENT_ID) == eventId;
- void _toggleEventId() {
- _eventState ^= _STATE_EVENT_ID;
- }
- bool get _isFiring => (_eventState & _STATE_FIRING) != 0;
- void _setRemoveAfterFiring() {
- assert(_isFiring);
- _eventState |= _STATE_REMOVE_AFTER_FIRING;
- }
- bool get _removeAfterFiring =>
- (_eventState & _STATE_REMOVE_AFTER_FIRING) != 0;
- void _onPause() {}
- void _onResume() {}
-}
-abstract class _BroadcastStreamController<T>
- implements StreamController<T>, _StreamControllerLifecycle<T>, _BroadcastSubscriptionLink, _EventSink<T>, _EventDispatch<T> {
- static const int _STATE_INITIAL = 0;
- static const int _STATE_EVENT_ID = 1;
- static const int _STATE_FIRING = 2;
- static const int _STATE_CLOSED = 4;
- static const int _STATE_ADDSTREAM = 8;
- final _NotificationHandler _onListen;
- final _NotificationHandler _onCancel;
- int _state;
- _BroadcastSubscriptionLink _next;
- _BroadcastSubscriptionLink _previous;
- _AddStreamState<T> _addStreamState;
- _Future _doneFuture;
- _BroadcastStreamController(this._onListen, this._onCancel)
- : _state = _STATE_INITIAL {
- _next = _previous = this;
- }
- Stream<T> get stream => new _BroadcastStream<T>(this);
- StreamSink<T> get sink => new _StreamSinkWrapper<T>(this);
- bool get isClosed => (_state & _STATE_CLOSED) != 0;
- bool get isPaused => false;
- bool get hasListener => !_isEmpty;
- bool get _hasOneListener {
- assert(!_isEmpty);
- return identical(_next._next, this);
- }
- bool get _isFiring => (_state & _STATE_FIRING) != 0;
- bool get _isAddingStream => (_state & _STATE_ADDSTREAM) != 0;
- bool get _mayAddEvent => (_state < _STATE_CLOSED);
- _Future _ensureDoneFuture() {
- if (_doneFuture != null) return _doneFuture;
- return _doneFuture = new _Future();
- }
- bool get _isEmpty => identical(_next, this);
- void _addListener(_BroadcastSubscription<T> subscription) {
- assert(identical(subscription._next, subscription));
- subscription._previous = _previous;
- subscription._next = this;
- this._previous._next = subscription;
- this._previous = subscription;
- subscription._eventState = (_state & _STATE_EVENT_ID);
- }
- void _removeListener(_BroadcastSubscription<T> subscription) {
- assert(identical(subscription._controller, this));
- assert(!identical(subscription._next, subscription));
- _BroadcastSubscriptionLink previous = subscription._previous;
- _BroadcastSubscriptionLink next = subscription._next;
- previous._next = next;
- next._previous = previous;
- subscription._next = subscription._previous = subscription;
- }
- StreamSubscription<T> _subscribe(void onData(T data), Function onError,
- void onDone(), bool cancelOnError) {
- if (isClosed) {
- if (onDone == null) onDone = _nullDoneHandler;
- return new _DoneStreamSubscription<T>(onDone);
- }
- StreamSubscription subscription = new _BroadcastSubscription<T>(
- this, onData, onError, onDone, cancelOnError);
- _addListener(DDC$RT.cast(subscription,
- DDC$RT.type((StreamSubscription<dynamic> _) {}),
- DDC$RT.type((_BroadcastSubscription<T> _) {}), "CastGeneral",
- """line 196, column 18 of dart:async/broadcast_stream_controller.dart: """,
- subscription is _BroadcastSubscription<T>, false));
- if (identical(_next, _previous)) {
- _runGuarded(_onListen);
- }
- return DDC$RT.cast(subscription,
- DDC$RT.type((StreamSubscription<dynamic> _) {}),
- DDC$RT.type((StreamSubscription<T> _) {}), "CastDynamic",
- """line 201, column 12 of dart:async/broadcast_stream_controller.dart: """,
- subscription is StreamSubscription<T>, false);
- }
- Future _recordCancel(_BroadcastSubscription<T> subscription) {
- if (identical(subscription._next, subscription)) return null;
- assert(!identical(subscription._next, subscription));
- if (subscription._isFiring) {
- subscription._setRemoveAfterFiring();
- } else {
- assert(!identical(subscription._next, subscription));
- _removeListener(subscription);
- if (!_isFiring && _isEmpty) {
- _callOnCancel();
- }
- }
- return null;
- }
- void _recordPause(StreamSubscription<T> subscription) {}
- void _recordResume(StreamSubscription<T> subscription) {}
- Error _addEventError() {
- if (isClosed) {
- return new StateError("Cannot add new events after calling close");
- }
- assert(_isAddingStream);
- return new StateError("Cannot add new events while doing an addStream");
- }
- void add(T data) {
- if (!_mayAddEvent) throw _addEventError();
- _sendData(data);
- }
- void addError(Object error, [StackTrace stackTrace]) {
- error = _nonNullError(error);
- if (!_mayAddEvent) throw _addEventError();
- AsyncError replacement = Zone.current.errorCallback(error, stackTrace);
- if (replacement != null) {
- error = _nonNullError(replacement.error);
- stackTrace = replacement.stackTrace;
- }
- _sendError(error, stackTrace);
- }
- Future close() {
- if (isClosed) {
- assert(_doneFuture != null);
- return _doneFuture;
- }
- if (!_mayAddEvent) throw _addEventError();
- _state |= _STATE_CLOSED;
- Future doneFuture = _ensureDoneFuture();
- _sendDone();
- return doneFuture;
- }
- Future get done => _ensureDoneFuture();
- Future addStream(Stream<T> stream, {bool cancelOnError: true}) {
- if (!_mayAddEvent) throw _addEventError();
- _state |= _STATE_ADDSTREAM;
- _addStreamState = ((__x3) => DDC$RT.cast(__x3,
- DDC$RT.type((_AddStreamState<dynamic> _) {}),
- DDC$RT.type((_AddStreamState<T> _) {}), "CastExact",
- """line 268, column 23 of dart:async/broadcast_stream_controller.dart: """,
- __x3 is _AddStreamState<T>,
- false))(new _AddStreamState(this, stream, cancelOnError));
- return _addStreamState.addStreamFuture;
- }
- void _add(T data) {
- _sendData(data);
- }
- void _addError(Object error, StackTrace stackTrace) {
- _sendError(error, stackTrace);
- }
- void _close() {
- assert(_isAddingStream);
- _AddStreamState addState = _addStreamState;
- _addStreamState = null;
- _state &= ~_STATE_ADDSTREAM;
- addState.complete();
- }
- void _forEachListener(
- void action(_BufferingStreamSubscription<T> subscription)) {
- if (_isFiring) {
- throw new StateError(
- "Cannot fire new event. Controller is already firing an event");
- }
- if (_isEmpty) return;
- int id = (_state & _STATE_EVENT_ID);
- _state ^= _STATE_EVENT_ID | _STATE_FIRING;
- _BroadcastSubscriptionLink link = _next;
- while (!identical(link, this)) {
- _BroadcastSubscription<T> subscription = DDC$RT.cast(link,
- _BroadcastSubscriptionLink,
- DDC$RT.type((_BroadcastSubscription<T> _) {}), "CastGeneral",
- """line 309, column 48 of dart:async/broadcast_stream_controller.dart: """,
- link is _BroadcastSubscription<T>, false);
- if (subscription._expectsEvent(id)) {
- subscription._eventState |= _BroadcastSubscription._STATE_FIRING;
- action(subscription);
- subscription._toggleEventId();
- link = subscription._next;
- if (subscription._removeAfterFiring) {
- _removeListener(subscription);
- }
- subscription._eventState &= ~_BroadcastSubscription._STATE_FIRING;
- } else {
- link = subscription._next;
- }
- }
- _state &= ~_STATE_FIRING;
- if (_isEmpty) {
- _callOnCancel();
- }
- }
- void _callOnCancel() {
- assert(_isEmpty);
- if (isClosed && _doneFuture._mayComplete) {
- _doneFuture._asyncComplete(null);
- }
- _runGuarded(_onCancel);
+), DDC$RT.type((_StreamControllerLifecycle<T> _) {
}
+), "CastDynamic", """line 8, column 67 of dart:async/broadcast_stream_controller.dart: """, controller is _StreamControllerLifecycle<T>, false));
+ bool get isBroadcast => true;
}
-class _SyncBroadcastStreamController<T> extends _BroadcastStreamController<T> {
- _SyncBroadcastStreamController(void onListen(), void onCancel())
- : super(onListen, onCancel);
- void _sendData(T data) {
- if (_isEmpty) return;
- if (_hasOneListener) {
- _state |= _BroadcastStreamController._STATE_FIRING;
- _BroadcastSubscription subscription = DDC$RT.cast(_next,
- _BroadcastSubscriptionLink,
- DDC$RT.type((_BroadcastSubscription<dynamic> _) {}), "CastGeneral",
- """line 350, column 45 of dart:async/broadcast_stream_controller.dart: """,
- _next is _BroadcastSubscription<dynamic>, true);
- subscription._add(data);
- _state &= ~_BroadcastStreamController._STATE_FIRING;
- if (_isEmpty) {
- _callOnCancel();
- }
- return;
- }
- _forEachListener((_BufferingStreamSubscription<T> subscription) {
- subscription._add(data);
- });
- }
- void _sendError(Object error, StackTrace stackTrace) {
- if (_isEmpty) return;
- _forEachListener((_BufferingStreamSubscription<T> subscription) {
- subscription._addError(error, stackTrace);
- });
- }
- void _sendDone() {
- if (!_isEmpty) {
- _forEachListener(((__x9) => DDC$RT.wrap(
- (dynamic f(_BroadcastSubscription<T> __u4)) {
- dynamic c(_BroadcastSubscription<T> x0) => f(DDC$RT.cast(x0,
- DDC$RT.type((_BufferingStreamSubscription<T> _) {}),
- DDC$RT.type((_BroadcastSubscription<T> _) {}), "CastParam",
- """line 372, column 24 of dart:async/broadcast_stream_controller.dart: """,
- x0 is _BroadcastSubscription<T>, false));
- return f == null ? null : c;
- }, __x9, DDC$RT.type((__t7<T> _) {}), DDC$RT.type((__t5<T> _) {}),
- "WrapLiteral",
- """line 372, column 24 of dart:async/broadcast_stream_controller.dart: """,
- __x9 is __t5<T>))((_BroadcastSubscription<T> subscription) {
- subscription._close();
- }));
- } else {
- assert(_doneFuture != null);
- assert(_doneFuture._mayComplete);
- _doneFuture._asyncComplete(null);
- }
- }
+ abstract class _BroadcastSubscriptionLink {_BroadcastSubscriptionLink _next;
+ _BroadcastSubscriptionLink _previous;
}
-class _AsyncBroadcastStreamController<T> extends _BroadcastStreamController<T> {
- _AsyncBroadcastStreamController(void onListen(), void onCancel())
- : super(onListen, onCancel);
- void _sendData(T data) {
- for (_BroadcastSubscriptionLink link = _next;
- !identical(link, this);
- link = link._next) {
- _BroadcastSubscription<T> subscription = DDC$RT.cast(link,
- _BroadcastSubscriptionLink,
- DDC$RT.type((_BroadcastSubscription<T> _) {}), "CastGeneral",
- """line 393, column 48 of dart:async/broadcast_stream_controller.dart: """,
- link is _BroadcastSubscription<T>, false);
- subscription._addPending(new _DelayedData(data));
- }
- }
- void _sendError(Object error, StackTrace stackTrace) {
- for (_BroadcastSubscriptionLink link = _next;
- !identical(link, this);
- link = link._next) {
- _BroadcastSubscription<T> subscription = DDC$RT.cast(link,
- _BroadcastSubscriptionLink,
- DDC$RT.type((_BroadcastSubscription<T> _) {}), "CastGeneral",
- """line 402, column 48 of dart:async/broadcast_stream_controller.dart: """,
- link is _BroadcastSubscription<T>, false);
- subscription._addPending(new _DelayedError(error, stackTrace));
- }
- }
- void _sendDone() {
- if (!_isEmpty) {
- for (_BroadcastSubscriptionLink link = _next;
- !identical(link, this);
- link = link._next) {
- _BroadcastSubscription<T> subscription = DDC$RT.cast(link,
- _BroadcastSubscriptionLink,
- DDC$RT.type((_BroadcastSubscription<T> _) {}), "CastGeneral",
- """line 412, column 50 of dart:async/broadcast_stream_controller.dart: """,
- link is _BroadcastSubscription<T>, false);
- subscription._addPending(const _DelayedDone());
- }
- } else {
- assert(_doneFuture != null);
- assert(_doneFuture._mayComplete);
- _doneFuture._asyncComplete(null);
- }
- }
+ class _BroadcastSubscription<T> extends _ControllerSubscription<T> implements _BroadcastSubscriptionLink {static const int _STATE_EVENT_ID = 1;
+ static const int _STATE_FIRING = 2;
+ static const int _STATE_REMOVE_AFTER_FIRING = 4;
+ int _eventState;
+ _BroadcastSubscriptionLink _next;
+ _BroadcastSubscriptionLink _previous;
+ _BroadcastSubscription(_StreamControllerLifecycle controller, void onData(T data), Function onError, void onDone(), bool cancelOnError) : super(DDC$RT.cast(controller, DDC$RT.type((_StreamControllerLifecycle<dynamic> _) {
}
-class _AsBroadcastStreamController<T> extends _SyncBroadcastStreamController<T>
- implements _EventDispatch<T> {
- _StreamImplEvents _pending;
- _AsBroadcastStreamController(void onListen(), void onCancel())
- : super(onListen, onCancel);
- bool get _hasPending => _pending != null && !_pending.isEmpty;
- void _addPendingEvent(_DelayedEvent event) {
- if (_pending == null) {
- _pending = new _StreamImplEvents();
- }
- _pending.add(event);
- }
- void add(T data) {
- if (!isClosed && _isFiring) {
- _addPendingEvent(new _DelayedData<T>(data));
- return;
- }
- super.add(data);
- while (_hasPending) {
- _pending.handleNext(this);
- }
- }
- void addError(Object error, [StackTrace stackTrace]) {
- if (!isClosed && _isFiring) {
- _addPendingEvent(new _DelayedError(error, stackTrace));
- return;
- }
- if (!_mayAddEvent) throw _addEventError();
- _sendError(error, stackTrace);
- while (_hasPending) {
- _pending.handleNext(this);
- }
- }
- Future close() {
- if (!isClosed && _isFiring) {
- _addPendingEvent(const _DelayedDone());
- _state |= _BroadcastStreamController._STATE_CLOSED;
- return super.done;
- }
- Future result = super.close();
- assert(!_hasPending);
- return result;
- }
- void _callOnCancel() {
- if (_hasPending) {
- _pending.clear();
- _pending = null;
- }
- super._callOnCancel();
- }
+), DDC$RT.type((_StreamControllerLifecycle<T> _) {
}
-class _DoneSubscription<T> implements StreamSubscription<T> {
- int _pauseCount = 0;
- void onData(void handleData(T data)) {}
- void onError(Function handleError) {}
- void onDone(void handleDone()) {}
- void pause([Future resumeSignal]) {
- if (resumeSignal != null) resumeSignal.then(_resume);
- _pauseCount++;
- }
- void resume() {
- _resume(null);
- }
- void _resume(_) {
- if (_pauseCount > 0) _pauseCount--;
- }
- Future cancel() {
- return new _Future.immediate(null);
- }
- bool get isPaused => _pauseCount > 0;
- Future asFuture([Object value]) => new _Future();
+), "CastDynamic", """line 36, column 15 of dart:async/broadcast_stream_controller.dart: """, controller is _StreamControllerLifecycle<T>, false), onData, onError, onDone, cancelOnError) {
+_next = _previous = this;
+}
+ _BroadcastStreamController get _controller => ((__x2) => DDC$RT.cast(__x2, DDC$RT.type((_StreamControllerLifecycle<T> _) {
+}
+), DDC$RT.type((_BroadcastStreamController<dynamic> _) {
+}
+), "CastGeneral", """line 40, column 49 of dart:async/broadcast_stream_controller.dart: """, __x2 is _BroadcastStreamController<dynamic>, true))(super._controller);
+ bool _expectsEvent(int eventId) => (_eventState & _STATE_EVENT_ID) == eventId;
+ void _toggleEventId() {
+_eventState ^= _STATE_EVENT_ID;
+}
+ bool get _isFiring => (_eventState & _STATE_FIRING) != 0;
+ void _setRemoveAfterFiring() {
+assert (_isFiring); _eventState |= _STATE_REMOVE_AFTER_FIRING;
+}
+ bool get _removeAfterFiring => (_eventState & _STATE_REMOVE_AFTER_FIRING) != 0;
+ void _onPause() {
+}
+ void _onResume() {
+}
+}
+ abstract class _BroadcastStreamController<T> implements StreamController<T>, _StreamControllerLifecycle<T>, _BroadcastSubscriptionLink, _EventSink<T>, _EventDispatch<T> {static const int _STATE_INITIAL = 0;
+ static const int _STATE_EVENT_ID = 1;
+ static const int _STATE_FIRING = 2;
+ static const int _STATE_CLOSED = 4;
+ static const int _STATE_ADDSTREAM = 8;
+ final _NotificationHandler _onListen;
+ final _NotificationHandler _onCancel;
+ int _state;
+ _BroadcastSubscriptionLink _next;
+ _BroadcastSubscriptionLink _previous;
+ _AddStreamState<T> _addStreamState;
+ _Future _doneFuture;
+ _BroadcastStreamController(this._onListen, this._onCancel) : _state = _STATE_INITIAL {
+_next = _previous = this;
+}
+ Stream<T> get stream => new _BroadcastStream<T>(this);
+ StreamSink<T> get sink => new _StreamSinkWrapper<T>(this);
+ bool get isClosed => (_state & _STATE_CLOSED) != 0;
+ bool get isPaused => false;
+ bool get hasListener => !_isEmpty;
+ bool get _hasOneListener {
+assert (!_isEmpty); return identical(_next._next, this);
+}
+ bool get _isFiring => (_state & _STATE_FIRING) != 0;
+ bool get _isAddingStream => (_state & _STATE_ADDSTREAM) != 0;
+ bool get _mayAddEvent => (_state < _STATE_CLOSED);
+ _Future _ensureDoneFuture() {
+if (_doneFuture != null) return _doneFuture;
+ return _doneFuture = new _Future();
+}
+ bool get _isEmpty => identical(_next, this);
+ void _addListener(_BroadcastSubscription<T> subscription) {
+assert (identical(subscription._next, subscription)); subscription._previous = _previous;
+ subscription._next = this;
+ this._previous._next = subscription;
+ this._previous = subscription;
+ subscription._eventState = (_state & _STATE_EVENT_ID);
+}
+ void _removeListener(_BroadcastSubscription<T> subscription) {
+assert (identical(subscription._controller, this)); assert (!identical(subscription._next, subscription)); _BroadcastSubscriptionLink previous = subscription._previous;
+ _BroadcastSubscriptionLink next = subscription._next;
+ previous._next = next;
+ next._previous = previous;
+ subscription._next = subscription._previous = subscription;
+}
+ StreamSubscription<T> _subscribe(void onData(T data), Function onError, void onDone(), bool cancelOnError) {
+if (isClosed) {
+if (onDone == null) onDone = _nullDoneHandler;
+ return new _DoneStreamSubscription<T>(onDone);
+}
+ StreamSubscription subscription = new _BroadcastSubscription<T>(this, onData, onError, onDone, cancelOnError);
+ _addListener(DDC$RT.cast(subscription, DDC$RT.type((StreamSubscription<dynamic> _) {
+}
+), DDC$RT.type((_BroadcastSubscription<T> _) {
+}
+), "CastGeneral", """line 196, column 18 of dart:async/broadcast_stream_controller.dart: """, subscription is _BroadcastSubscription<T>, false));
+ if (identical(_next, _previous)) {
+_runGuarded(_onListen);
+}
+ return DDC$RT.cast(subscription, DDC$RT.type((StreamSubscription<dynamic> _) {
+}
+), DDC$RT.type((StreamSubscription<T> _) {
+}
+), "CastDynamic", """line 201, column 12 of dart:async/broadcast_stream_controller.dart: """, subscription is StreamSubscription<T>, false);
+}
+ Future _recordCancel(_BroadcastSubscription<T> subscription) {
+if (identical(subscription._next, subscription)) return null;
+ assert (!identical(subscription._next, subscription)); if (subscription._isFiring) {
+subscription._setRemoveAfterFiring();
+}
+ else {
+assert (!identical(subscription._next, subscription)); _removeListener(subscription);
+ if (!_isFiring && _isEmpty) {
+_callOnCancel();
+}
+}
+ return null;
+}
+ void _recordPause(StreamSubscription<T> subscription) {
+}
+ void _recordResume(StreamSubscription<T> subscription) {
+}
+ Error _addEventError() {
+if (isClosed) {
+return new StateError("Cannot add new events after calling close");
+}
+ assert (_isAddingStream); return new StateError("Cannot add new events while doing an addStream");
+}
+ void add(T data) {
+if (!_mayAddEvent) throw _addEventError();
+ _sendData(data);
+}
+ void addError(Object error, [StackTrace stackTrace]) {
+error = _nonNullError(error);
+ if (!_mayAddEvent) throw _addEventError();
+ AsyncError replacement = Zone.current.errorCallback(error, stackTrace);
+ if (replacement != null) {
+error = _nonNullError(replacement.error);
+ stackTrace = replacement.stackTrace;
+}
+ _sendError(error, stackTrace);
+}
+ Future close() {
+if (isClosed) {
+assert (_doneFuture != null); return _doneFuture;
+}
+ if (!_mayAddEvent) throw _addEventError();
+ _state |= _STATE_CLOSED;
+ Future doneFuture = _ensureDoneFuture();
+ _sendDone();
+ return doneFuture;
+}
+ Future get done => _ensureDoneFuture();
+ Future addStream(Stream<T> stream, {
+bool cancelOnError : true}
+) {
+if (!_mayAddEvent) throw _addEventError();
+ _state |= _STATE_ADDSTREAM;
+ _addStreamState = ((__x3) => DDC$RT.cast(__x3, DDC$RT.type((_AddStreamState<dynamic> _) {
+}
+), DDC$RT.type((_AddStreamState<T> _) {
+}
+), "CastExact", """line 268, column 23 of dart:async/broadcast_stream_controller.dart: """, __x3 is _AddStreamState<T>, false))(new _AddStreamState(this, stream, cancelOnError));
+ return _addStreamState.addStreamFuture;
+}
+ void _add(T data) {
+_sendData(data);
+}
+ void _addError(Object error, StackTrace stackTrace) {
+_sendError(error, stackTrace);
+}
+ void _close() {
+assert (_isAddingStream); _AddStreamState addState = _addStreamState;
+ _addStreamState = null;
+ _state &= ~_STATE_ADDSTREAM;
+ addState.complete();
+}
+ void _forEachListener(void action(_BufferingStreamSubscription<T> subscription)) {
+if (_isFiring) {
+throw new StateError("Cannot fire new event. Controller is already firing an event");
+}
+ if (_isEmpty) return; int id = (_state & _STATE_EVENT_ID);
+ _state ^= _STATE_EVENT_ID | _STATE_FIRING;
+ _BroadcastSubscriptionLink link = _next;
+ while (!identical(link, this)) {
+_BroadcastSubscription<T> subscription = DDC$RT.cast(link, _BroadcastSubscriptionLink, DDC$RT.type((_BroadcastSubscription<T> _) {
+}
+), "CastGeneral", """line 309, column 48 of dart:async/broadcast_stream_controller.dart: """, link is _BroadcastSubscription<T>, false);
+ if (subscription._expectsEvent(id)) {
+subscription._eventState |= _BroadcastSubscription._STATE_FIRING;
+ action(subscription);
+ subscription._toggleEventId();
+ link = subscription._next;
+ if (subscription._removeAfterFiring) {
+ _removeListener(subscription);
+ }
+ subscription._eventState &= ~_BroadcastSubscription._STATE_FIRING;
+}
+ else {
+link = subscription._next;
+}
+}
+ _state &= ~_STATE_FIRING;
+ if (_isEmpty) {
+_callOnCancel();
+}
+}
+ void _callOnCancel() {
+assert (_isEmpty); if (isClosed && _doneFuture._mayComplete) {
+_doneFuture._asyncComplete(null);
+}
+ _runGuarded(_onCancel);
+}
+}
+ class _SyncBroadcastStreamController<T> extends _BroadcastStreamController<T> {_SyncBroadcastStreamController(void onListen(), void onCancel()) : super(onListen, onCancel);
+ void _sendData(T data) {
+if (_isEmpty) return; if (_hasOneListener) {
+_state |= _BroadcastStreamController._STATE_FIRING;
+ _BroadcastSubscription subscription = DDC$RT.cast(_next, _BroadcastSubscriptionLink, DDC$RT.type((_BroadcastSubscription<dynamic> _) {
+}
+), "CastGeneral", """line 350, column 45 of dart:async/broadcast_stream_controller.dart: """, _next is _BroadcastSubscription<dynamic>, true);
+ subscription._add(data);
+ _state &= ~_BroadcastStreamController._STATE_FIRING;
+ if (_isEmpty) {
+_callOnCancel();
+}
+ return;}
+ _forEachListener((_BufferingStreamSubscription<T> subscription) {
+subscription._add(data);
+}
+);
+}
+ void _sendError(Object error, StackTrace stackTrace) {
+if (_isEmpty) return; _forEachListener((_BufferingStreamSubscription<T> subscription) {
+subscription._addError(error, stackTrace);
+}
+);
+}
+ void _sendDone() {
+if (!_isEmpty) {
+_forEachListener(((__x9) => DDC$RT.wrap((dynamic f(_BroadcastSubscription<T> __u4)) {
+dynamic c(_BroadcastSubscription<T> x0) => f(DDC$RT.cast(x0, DDC$RT.type((_BufferingStreamSubscription<T> _) {
+}
+), DDC$RT.type((_BroadcastSubscription<T> _) {
+}
+), "CastParam", """line 372, column 24 of dart:async/broadcast_stream_controller.dart: """, x0 is _BroadcastSubscription<T>, false));
+ return f == null ? null : c;
+}
+, __x9, DDC$RT.type((__t7<T> _) {
+}
+), DDC$RT.type((__t5<T> _) {
+}
+), "WrapLiteral", """line 372, column 24 of dart:async/broadcast_stream_controller.dart: """, __x9 is __t5<T>))((_BroadcastSubscription<T> subscription) {
+subscription._close();
+}
+));
+}
+ else {
+assert (_doneFuture != null); assert (_doneFuture._mayComplete); _doneFuture._asyncComplete(null);
+}
+}
+}
+ class _AsyncBroadcastStreamController<T> extends _BroadcastStreamController<T> {_AsyncBroadcastStreamController(void onListen(), void onCancel()) : super(onListen, onCancel);
+ void _sendData(T data) {
+for (_BroadcastSubscriptionLink link = _next;
+ !identical(link, this);
+ link = link._next) {
+_BroadcastSubscription<T> subscription = DDC$RT.cast(link, _BroadcastSubscriptionLink, DDC$RT.type((_BroadcastSubscription<T> _) {
+}
+), "CastGeneral", """line 393, column 48 of dart:async/broadcast_stream_controller.dart: """, link is _BroadcastSubscription<T>, false);
+ subscription._addPending(new _DelayedData(data));
+}
+}
+ void _sendError(Object error, StackTrace stackTrace) {
+for (_BroadcastSubscriptionLink link = _next;
+ !identical(link, this);
+ link = link._next) {
+_BroadcastSubscription<T> subscription = DDC$RT.cast(link, _BroadcastSubscriptionLink, DDC$RT.type((_BroadcastSubscription<T> _) {
+}
+), "CastGeneral", """line 402, column 48 of dart:async/broadcast_stream_controller.dart: """, link is _BroadcastSubscription<T>, false);
+ subscription._addPending(new _DelayedError(error, stackTrace));
+}
+}
+ void _sendDone() {
+if (!_isEmpty) {
+for (_BroadcastSubscriptionLink link = _next;
+ !identical(link, this);
+ link = link._next) {
+_BroadcastSubscription<T> subscription = DDC$RT.cast(link, _BroadcastSubscriptionLink, DDC$RT.type((_BroadcastSubscription<T> _) {
+}
+), "CastGeneral", """line 412, column 50 of dart:async/broadcast_stream_controller.dart: """, link is _BroadcastSubscription<T>, false);
+ subscription._addPending(const _DelayedDone());
+}
+}
+ else {
+assert (_doneFuture != null); assert (_doneFuture._mayComplete); _doneFuture._asyncComplete(null);
+}
+}
+}
+ class _AsBroadcastStreamController<T> extends _SyncBroadcastStreamController<T> implements _EventDispatch<T> {_StreamImplEvents _pending;
+ _AsBroadcastStreamController(void onListen(), void onCancel()) : super(onListen, onCancel);
+ bool get _hasPending => _pending != null && !_pending.isEmpty;
+ void _addPendingEvent(_DelayedEvent event) {
+if (_pending == null) {
+_pending = new _StreamImplEvents();
+}
+ _pending.add(event);
+}
+ void add(T data) {
+if (!isClosed && _isFiring) {
+_addPendingEvent(new _DelayedData<T>(data));
+ return;}
+ super.add(data);
+ while (_hasPending) {
+_pending.handleNext(this);
+}
+}
+ void addError(Object error, [StackTrace stackTrace]) {
+if (!isClosed && _isFiring) {
+_addPendingEvent(new _DelayedError(error, stackTrace));
+ return;}
+ if (!_mayAddEvent) throw _addEventError();
+ _sendError(error, stackTrace);
+ while (_hasPending) {
+_pending.handleNext(this);
+}
+}
+ Future close() {
+if (!isClosed && _isFiring) {
+_addPendingEvent(const _DelayedDone());
+ _state |= _BroadcastStreamController._STATE_CLOSED;
+ return super.done;
+}
+ Future result = super.close();
+ assert (!_hasPending); return result;
+}
+ void _callOnCancel() {
+if (_hasPending) {
+_pending.clear();
+ _pending = null;
+}
+ super._callOnCancel();
+}
+}
+ class _DoneSubscription<T> implements StreamSubscription<T> {int _pauseCount = 0;
+ void onData(void handleData(T data)) {
+}
+ void onError(Function handleError) {
+}
+ void onDone(void handleDone()) {
+}
+ void pause([Future resumeSignal]) {
+if (resumeSignal != null) resumeSignal.then(_resume);
+ _pauseCount++;
+}
+ void resume() {
+_resume(null);
+}
+ void _resume(_) {
+if (_pauseCount > 0) _pauseCount--;
+}
+ Future cancel() {
+return new _Future.immediate(null);
+}
+ bool get isPaused => _pauseCount > 0;
+ Future asFuture([Object value]) => new _Future();
}
-typedef void __t5<T>(_BufferingStreamSubscription<T> __u6);
-typedef dynamic __t7<T>(_BroadcastSubscription<T> __u8);
+ typedef void __t5<T>(_BufferingStreamSubscription<T> __u6);
+ typedef dynamic __t7<T>(_BroadcastSubscription<T> __u8);
« test/dart_codegen/expect/_internal/iterable.dart ('K') | « test/dart_codegen/expect/async/async_error.dart ('k') | test/dart_codegen/expect/async/deferred_load.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698