Index: runtime/bin/socket_patch.dart |
diff --git a/runtime/bin/socket_patch.dart b/runtime/bin/socket_patch.dart |
index 3b9aaae6882d2cd05a4c2718b03724b643815fa2..64ff5642e08aeb5220dfc319582fdf9b59e2bdb7 100644 |
--- a/runtime/bin/socket_patch.dart |
+++ b/runtime/bin/socket_patch.dart |
@@ -434,7 +434,7 @@ class _RawServerSocket extends Stream<RawSocket> |
if (socket != null) _controller.add(new _RawSocket(socket)); |
}, |
error: (e) { |
- _controller.signalError(new AsyncError(e)); |
+ _controller.addError(new AsyncError(e)); |
_controller.close(); |
} |
); |
@@ -507,7 +507,7 @@ class _RawSocket extends Stream<RawSocketEvent> |
}, |
closed: () => _controller.add(RawSocketEvent.READ_CLOSED), |
error: (e) { |
- _controller.signalError(new AsyncError(e)); |
+ _controller.addError(new AsyncError(e)); |
close(); |
} |
); |
@@ -863,7 +863,7 @@ class _Socket extends Stream<List<int>> implements Socket { |
void _onError(error) { |
if (!_controllerClosed) { |
_controllerClosed = true; |
- _controller.signalError(error); |
+ _controller.addError(error); |
_controller.close(); |
} |
_done(error); |