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; |