Index: runtime/bin/socket_patch.dart |
diff --git a/runtime/bin/socket_patch.dart b/runtime/bin/socket_patch.dart |
index a381e184b9be0a87708cd5b10ef3566e62d69d78..779469a709a1dc10f255dab7eb87ef13e9fbf62c 100644 |
--- a/runtime/bin/socket_patch.dart |
+++ b/runtime/bin/socket_patch.dart |
@@ -432,8 +432,10 @@ class _RawServerSocket extends Stream<RawSocket> |
_RawServerSocket(this._socket) { |
_controller = new StreamController( |
- onSubscriptionStateChange: _onSubscriptionStateChange, |
- onPauseStateChange: _onPauseStateChange); |
+ onListen: _onSubscriptionStateChange, |
+ onCancel: _onSubscriptionStateChange, |
+ onPause: _onPauseStateChange, |
+ onResume: _onPauseStateChange); |
_socket.closeFuture.then((_) => _controller.close()); |
_socket.setHandlers( |
read: () { |
@@ -501,8 +503,10 @@ class _RawSocket extends Stream<RawSocketEvent> |
_RawSocket(this._socket) { |
_controller = new StreamController( |
- onSubscriptionStateChange: _onSubscriptionStateChange, |
- onPauseStateChange: _onPauseStateChange); |
+ onListen: _onSubscriptionStateChange, |
+ onCancel: _onSubscriptionStateChange, |
+ onPause: _onPauseStateChange, |
+ onResume: _onPauseStateChange); |
_socket.closeFuture.then((_) => _controller.close()); |
_socket.setHandlers( |
read: () => _controller.add(RawSocketEvent.READ), |
@@ -761,8 +765,10 @@ class _Socket extends Stream<List<int>> implements Socket { |
_Socket(RawSocket this._raw) { |
_controller = new StreamController<List<int>>( |
- onSubscriptionStateChange: _onSubscriptionStateChange, |
- onPauseStateChange: _onPauseStateChange); |
+ onListen: _onSubscriptionStateChange, |
+ onCancel: _onSubscriptionStateChange, |
+ onPause: _onPauseStateChange, |
+ onResume: _onPauseStateChange); |
_consumer = new _SocketStreamConsumer(this); |
_sink = new IOSink(_consumer); |