| Index: sdk/lib/async/stream_impl.dart
|
| diff --git a/sdk/lib/async/stream_impl.dart b/sdk/lib/async/stream_impl.dart
|
| index 3f77294619a6e3d3b1e23f7794fc6b51e8700e95..19bdb699a91f77a9d268a77c4a4a9de164069b64 100644
|
| --- a/sdk/lib/async/stream_impl.dart
|
| +++ b/sdk/lib/async/stream_impl.dart
|
| @@ -1081,3 +1081,15 @@ class _StreamIteratorImpl<T> implements StreamIterator<T> {
|
| _state = _STATE_EXTRA_DONE;
|
| }
|
| }
|
| +
|
| +/** An empty broadcast stream, sending a done event as soon as possible. */
|
| +class _EmptyStream<T> extends Stream<T> {
|
| + const _EmptyStream() : super._internal();
|
| + bool get isBroadcast => true;
|
| + StreamSubscription<T> listen(void onData(T data),
|
| + {Function onError,
|
| + void onDone(),
|
| + bool cancelOnError}) {
|
| + return new _DoneStreamSubscription<T>(onDone);
|
| + }
|
| +}
|
|
|