Index: sdk/lib/io/io_sink.dart |
diff --git a/sdk/lib/io/io_sink.dart b/sdk/lib/io/io_sink.dart |
index df3a7daac36faf6ca070c8c62cc851098e742dfa..843856825397c21d94adc386c1ca23a8d0898893 100644 |
--- a/sdk/lib/io/io_sink.dart |
+++ b/sdk/lib/io/io_sink.dart |
@@ -194,8 +194,10 @@ class _IOSinkImpl<T> implements IOSink<T> { |
StreamController<List<int>> get _controller { |
if (_controllerInstance == null) { |
_controllerInstance = new StreamController<List<int>>( |
- onPauseStateChange: _onPauseStateChange, |
- onSubscriptionStateChange: _onSubscriptionStateChange); |
+ onListen: _onSubscriptionStateChange, |
+ onPause: _onPauseStateChange, |
+ onResume: _onPauseStateChange, |
+ onCancel: _onSubscriptionStateChange); |
var future = _controller.stream.pipe(_target); |
future.then((_) => _completeWriteStreamCompleter(), |
onError: (error) => _completeWriteStreamCompleter(error)); |