| 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(
|
|
|