| Index: sdk/lib/async/stream_impl.dart
|
| diff --git a/sdk/lib/async/stream_impl.dart b/sdk/lib/async/stream_impl.dart
|
| index 40cc3da63e5ec550249be0dcce588766a272a4a9..43e3f6508089e8598b753af5763567ed2a4ffe25 100644
|
| --- a/sdk/lib/async/stream_impl.dart
|
| +++ b/sdk/lib/async/stream_impl.dart
|
| @@ -755,8 +755,11 @@ class _AsBroadcastStream<T> extends Stream<T> {
|
| onError: _controller.addError,
|
| onDone: _controller.close);
|
| }
|
| - return _controller.stream.listen(onData, onError: onError, onDone: onDone,
|
| - cancelOnError: cancelOnError);
|
| + if (onData == null) onData = _nullDataHandler;
|
| + if (onError == null) onError = _nullErrorHandler;
|
| + if (onDone == null) onDone = _nullDoneHandler;
|
| + cancelOnError = identical(true, cancelOnError);
|
| + return _controller._subscribe(onData, onError, onDone, cancelOnError);
|
| }
|
|
|
| void _onCancel() {
|
|
|