Index: runtime/bin/socket_patch.dart |
diff --git a/runtime/bin/socket_patch.dart b/runtime/bin/socket_patch.dart |
index 0316652c4b3ccc2ae28ef7e13a582a0eae5fb8ac..c6c1d806d232f4ac7a243d980c48e5936fd85336 100644 |
--- a/runtime/bin/socket_patch.dart |
+++ b/runtime/bin/socket_patch.dart |
@@ -441,14 +441,14 @@ class _RawServerSocket extends Stream<RawSocket> |
if (socket != null) _controller.add(new _RawSocket(socket)); |
}, |
error: (e) { |
- _controller.addError(new AsyncError(e)); |
+ _controller.addError(e); |
_controller.close(); |
} |
); |
} |
StreamSubscription<RawSocket> listen(void onData(RawSocket event), |
- {void onError(AsyncError error), |
+ {void onError(Object error), |
void onDone(), |
bool unsubscribeOnError}) { |
return _controller.stream.listen( |
@@ -514,7 +514,7 @@ class _RawSocket extends Stream<RawSocketEvent> |
}, |
closed: () => _controller.add(RawSocketEvent.READ_CLOSED), |
error: (e) { |
- _controller.addError(new AsyncError(e)); |
+ _controller.addError(e); |
close(); |
} |
); |
@@ -535,7 +535,7 @@ class _RawSocket extends Stream<RawSocketEvent> |
} |
StreamSubscription<RawSocketEvent> listen(void onData(RawSocketEvent event), |
- {void onError(AsyncError error), |
+ {void onError(Object error), |
void onDone(), |
bool unsubscribeOnError}) { |
return _controller.stream.listen( |
@@ -629,7 +629,7 @@ class _ServerSocket extends Stream<Socket> |
_ServerSocket(this._socket); |
StreamSubscription<Socket> listen(void onData(Socket event), |
- {void onError(AsyncError error), |
+ {void onError(error), |
void onDone(), |
bool unsubscribeOnError}) { |
return _socket.map((rawSocket) => new _Socket(rawSocket)).listen( |
@@ -784,7 +784,7 @@ class _Socket extends Stream<List<int>> implements Socket { |
_NativeSocket get _nativeSocket => _raw._socket; |
StreamSubscription<List<int>> listen(void onData(List<int> event), |
- {void onError(AsyncError error), |
+ {void onError(error), |
void onDone(), |
bool unsubscribeOnError}) { |
return _controller.stream.listen( |