Index: sdk/lib/isolate/isolate_stream.dart |
diff --git a/sdk/lib/isolate/isolate_stream.dart b/sdk/lib/isolate/isolate_stream.dart |
index a0a30b0095007adf77542dc67752e0504bae1d4c..d72389faa355903e40ff38162f2c4bdeb9fda831 100644 |
--- a/sdk/lib/isolate/isolate_stream.dart |
+++ b/sdk/lib/isolate/isolate_stream.dart |
@@ -52,7 +52,7 @@ class _CloseToken { |
class IsolateStream extends Stream<dynamic> { |
bool _isClosed = false; |
final ReceivePort _port; |
- StreamController _controller = new StreamController.multiSubscription(); |
+ StreamController _controller = new StreamController.broadcast(); |
IsolateStream._fromOriginalReceivePort(this._port) { |
_port.receive((message, replyTo) { |
@@ -95,10 +95,10 @@ class IsolateStream extends Stream<dynamic> { |
{ void onError(AsyncError error), |
void onDone(), |
bool unsubscribeOnError}) { |
- return _controller.listen(onData, |
- onError: onError, |
- onDone: onDone, |
- unsubscribeOnError: unsubscribeOnError); |
+ return _controller.stream.listen(onData, |
+ onError: onError, |
+ onDone: onDone, |
+ unsubscribeOnError: unsubscribeOnError); |
} |
dynamic _unmangleMessage(var message) { |