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