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); |
+ } |
+} |