| Index: sdk/lib/async/stream_pipe.dart
|
| diff --git a/sdk/lib/async/stream_pipe.dart b/sdk/lib/async/stream_pipe.dart
|
| index d26b0c5f64c86fc97c1df3c06a879e81c9c480fd..caf94a1f02b570392891ac028440ac61d9a5859e 100644
|
| --- a/sdk/lib/async/stream_pipe.dart
|
| +++ b/sdk/lib/async/stream_pipe.dart
|
| @@ -326,6 +326,9 @@ class _TakeStream<T> extends _ForwardingStream<T, T> {
|
| Function onError,
|
| void onDone(),
|
| bool cancelOnError) {
|
| + if (_count == 0) {
|
| + return new _DoneSubscription<T>(onDone);
|
| + }
|
| return new _StateStreamSubscription<T>(
|
| this, onData, onError, onDone, cancelOnError, _count);
|
| }
|
|
|