Index: sdk/lib/async/stream_impl.dart |
diff --git a/sdk/lib/async/stream_impl.dart b/sdk/lib/async/stream_impl.dart |
index 19bdb699a91f77a9d268a77c4a4a9de164069b64..c23b0f040f6924d75f1b922f150e1d3765b28d3c 100644 |
--- a/sdk/lib/async/stream_impl.dart |
+++ b/sdk/lib/async/stream_impl.dart |
@@ -512,7 +512,7 @@ class _GeneratedStreamImpl<T> extends _StreamImpl<T> { |
bool cancelOnError) { |
if (_isUsed) throw new StateError("Stream has already been listened to."); |
_isUsed = true; |
- return new _BufferingStreamSubscription( |
+ return new _BufferingStreamSubscription<T>( |
onData, onError, onDone, cancelOnError).._setPendingEvents(_pending()); |
} |
} |