| Index: sdk/lib/_internal/pub_generated/lib/src/error_group.dart
|
| diff --git a/sdk/lib/_internal/pub/lib/src/error_group.dart b/sdk/lib/_internal/pub_generated/lib/src/error_group.dart
|
| similarity index 93%
|
| copy from sdk/lib/_internal/pub/lib/src/error_group.dart
|
| copy to sdk/lib/_internal/pub_generated/lib/src/error_group.dart
|
| index c479a24e9969eefe12e8d788c4520d482bcb6b6a..7efebf3cd6bb18dd3ae95f0403d3f73becb21264 100644
|
| --- a/sdk/lib/_internal/pub/lib/src/error_group.dart
|
| +++ b/sdk/lib/_internal/pub_generated/lib/src/error_group.dart
|
| @@ -69,8 +69,8 @@ class ErrorGroup {
|
| /// error, it's a [StateError] to try to register a new [Future].
|
| Future registerFuture(Future future) {
|
| if (_isDone) {
|
| - throw new StateError("Can't register new members on a complete "
|
| - "ErrorGroup.");
|
| + throw new StateError(
|
| + "Can't register new members on a complete " "ErrorGroup.");
|
| }
|
|
|
| var wrapped = new _ErrorGroupFuture(this, future);
|
| @@ -92,8 +92,8 @@ class ErrorGroup {
|
| /// error, it's a [StateError] to try to register a new [Stream].
|
| Stream registerStream(Stream stream) {
|
| if (_isDone) {
|
| - throw new StateError("Can't register new members on a complete "
|
| - "ErrorGroup.");
|
| + throw new StateError(
|
| + "Can't register new members on a complete " "ErrorGroup.");
|
| }
|
|
|
| var wrapped = new _ErrorGroupStream(this, stream);
|
| @@ -136,7 +136,9 @@ class ErrorGroup {
|
|
|
| _isDone = true;
|
| _done._signalError(error, stackTrace);
|
| - if (!caught && !_done._hasListeners) scheduleMicrotask((){ throw error; });
|
| + if (!caught && !_done._hasListeners) scheduleMicrotask(() {
|
| + throw error;
|
| + });
|
| }
|
|
|
| /// Notifies [this] that one of its member [Future]s is complete.
|
| @@ -257,12 +259,12 @@ class _ErrorGroupStream extends Stream {
|
| /// Creates a new [_ErrorGroupFuture] that's a child of [_group] and wraps
|
| /// [inner].
|
| _ErrorGroupStream(this._group, Stream inner)
|
| - : _controller = new StreamController(sync: true) {
|
| + : _controller = new StreamController(sync: true) {
|
| // Use old-style asBroadcastStream behavior - cancel source _subscription
|
| // the first time the stream has no listeners.
|
| - _stream = inner.isBroadcast
|
| - ? _controller.stream.asBroadcastStream(onCancel: (sub) => sub.cancel())
|
| - : _controller.stream;
|
| + _stream = inner.isBroadcast ?
|
| + _controller.stream.asBroadcastStream(onCancel: (sub) => sub.cancel()) :
|
| + _controller.stream;
|
| _subscription = inner.listen((v) {
|
| _controller.add(v);
|
| }, onError: (e, [stackTrace]) {
|
| @@ -274,10 +276,10 @@ class _ErrorGroupStream extends Stream {
|
| });
|
| }
|
|
|
| - StreamSubscription listen(void onData(value),
|
| - {Function onError, void onDone(),
|
| - bool cancelOnError}) {
|
| - return _stream.listen(onData,
|
| + StreamSubscription listen(void onData(value), {Function onError, void
|
| + onDone(), bool cancelOnError}) {
|
| + return _stream.listen(
|
| + onData,
|
| onError: onError,
|
| onDone: onDone,
|
| cancelOnError: true);
|
|
|