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