Index: sdk/lib/async/stream_impl.dart |
diff --git a/sdk/lib/async/stream_impl.dart b/sdk/lib/async/stream_impl.dart |
index 394e1c6a7c72b51b25fc7df35554941a94e2e2e5..eef9660404d6261e713bc8424eef0a4d01de0958 100644 |
--- a/sdk/lib/async/stream_impl.dart |
+++ b/sdk/lib/async/stream_impl.dart |
@@ -1036,7 +1036,10 @@ class _StreamIteratorImpl<T> implements StreamIterator<T> { |
} else { |
_clear(); |
} |
- return subscription.cancel(); |
+ // If the stream is done, the subscription will have been cleared. |
+ return subscription == null |
+ ? new _Future<Null>.immediate(null) |
floitsch
2015/02/02 22:00:12
This does not belong into this CL.
Create a new C
sigurdm
2015/02/03 16:59:33
Ok.
|
+ : subscription.cancel(); |
} |
void _onData(T data) { |