Index: sdk/lib/async/stream_impl.dart |
diff --git a/sdk/lib/async/stream_impl.dart b/sdk/lib/async/stream_impl.dart |
index c23b0f040f6924d75f1b922f150e1d3765b28d3c..c5481a3da442422f795f34da110c58dce77ba8c0 100644 |
--- a/sdk/lib/async/stream_impl.dart |
+++ b/sdk/lib/async/stream_impl.dart |
@@ -839,7 +839,8 @@ class _AsBroadcastStream<T> extends Stream<T> { |
void _onCancel() { |
bool shutdown = (_controller == null) || _controller.isClosed; |
if (_onCancelHandler != null) { |
- _zone.runUnary(_onCancelHandler, new _BroadcastSubscriptionWrapper(this)); |
+ _zone.runUnary( |
+ _onCancelHandler, new _BroadcastSubscriptionWrapper<T>(this)); |
} |
if (shutdown) { |
if (_subscription != null) { |
@@ -851,7 +852,8 @@ class _AsBroadcastStream<T> extends Stream<T> { |
void _onListen() { |
if (_onListenHandler != null) { |
- _zone.runUnary(_onListenHandler, new _BroadcastSubscriptionWrapper(this)); |
+ _zone.runUnary( |
+ _onListenHandler, new _BroadcastSubscriptionWrapper<T>(this)); |
} |
} |