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