| Index: sdk/lib/async/stream_controller.dart
|
| diff --git a/sdk/lib/async/stream_controller.dart b/sdk/lib/async/stream_controller.dart
|
| index 26bbb14706cb55d971db51bce691f7f41a0f6183..f856b61526d1addf93a50ba25bfa134929433fa6 100644
|
| --- a/sdk/lib/async/stream_controller.dart
|
| +++ b/sdk/lib/async/stream_controller.dart
|
| @@ -639,8 +639,8 @@ abstract class _StreamController<T> implements StreamController<T>,
|
| throw new StateError("Stream has already been listened to.");
|
| }
|
| _ControllerSubscription subscription =
|
| - new _ControllerSubscription(this, onData, onError, onDone,
|
| - cancelOnError);
|
| + new _ControllerSubscription<T>(this, onData, onError, onDone,
|
| + cancelOnError);
|
|
|
| _PendingEvents pendingEvents = _pendingEvents;
|
| _state |= _STATE_SUBSCRIBED;
|
|
|