Index: sdk/lib/io/http_impl.dart |
diff --git a/sdk/lib/io/http_impl.dart b/sdk/lib/io/http_impl.dart |
index aa7de54a4f56fa14a9b964478c46838de0f0e14f..5c3b38680b38196c50ef519a057bd45fd357c8d2 100644 |
--- a/sdk/lib/io/http_impl.dart |
+++ b/sdk/lib/io/http_impl.dart |
@@ -35,7 +35,7 @@ class _HttpIncoming extends Stream<List<int>> { |
} |
StreamSubscription<List<int>> listen(void onData(List<int> event), |
- {void onError(AsyncError error), |
+ {void onError(error), |
void onDone(), |
bool unsubscribeOnError}) { |
return _stream.listen(onData, |
@@ -106,7 +106,7 @@ class _HttpRequest extends _HttpInboundMessage implements HttpRequest { |
} |
StreamSubscription<List<int>> listen(void onData(List<int> event), |
- {void onError(AsyncError error), |
+ {void onError(error), |
void onDone(), |
bool unsubscribeOnError}) { |
return _incoming.listen(onData, |
@@ -231,7 +231,7 @@ class _HttpClientResponse |
} |
StreamSubscription<List<int>> listen(void onData(List<int> event), |
- {void onError(AsyncError error), |
+ {void onError(error), |
void onDone(), |
bool unsubscribeOnError}) { |
var stream = _incoming; |
@@ -442,7 +442,7 @@ abstract class _HttpOutboundMessage<T> implements IOSink { |
_dataSink.add(data); |
} |
- void addError(AsyncError error) { |
+ void addError(error) { |
_dataSink.addError(error); |
} |
@@ -877,7 +877,7 @@ class _HttpClientRequest extends _HttpOutboundMessage<HttpClientResponse> |
}); |
} |
- void _onError(AsyncError error) { |
+ void _onError(error) { |
_responseCompleter.completeError(error); |
} |
@@ -976,11 +976,11 @@ class _ContentLengthValidator |
void handleData(List<int> data, EventSink<List<int>> sink) { |
_bytesWritten += data.length; |
if (_bytesWritten > expectedContentLength) { |
- sink.addError(new AsyncError(new HttpException( |
+ sink.addError(new HttpException( |
"Content size exceeds specified contentLength. " |
"$_bytesWritten bytes written while expected " |
"$expectedContentLength. " |
- "[${new String.fromCharCodes(data)}]"))); |
+ "[${new String.fromCharCodes(data)}]")); |
sink.close(); |
} else { |
sink.add(data); |
@@ -989,10 +989,10 @@ class _ContentLengthValidator |
void handleDone(EventSink<List<int>> sink) { |
if (_bytesWritten < expectedContentLength) { |
- sink.addError(new AsyncError(new HttpException( |
+ sink.addError(new HttpException( |
"Content size below specified contentLength. " |
" $_bytesWritten bytes written while expected " |
- "$expectedContentLength."))); |
+ "$expectedContentLength.")); |
} |
sink.close(); |
} |
@@ -1384,7 +1384,7 @@ class _HttpClient implements HttpClient { |
return new _ConnnectionInfo(connection, proxy); |
}, onError: (error) { |
// Continue with next proxy. |
- return connect(error.error); |
+ return connect(error); |
}); |
} |
return connect(new HttpException("No proxies given")); |
@@ -1592,7 +1592,7 @@ class _HttpServer extends Stream<HttpRequest> implements HttpServer { |
: _closeServer = false; |
StreamSubscription<HttpRequest> listen(void onData(HttpRequest event), |
- {void onError(AsyncError error), |
+ {void onError(error), |
void onDone(), |
bool unsubscribeOnError}) { |
_serverSocket.listen( |
@@ -1638,7 +1638,7 @@ class _HttpServer extends Stream<HttpRequest> implements HttpServer { |
_controller.add(request); |
} |
- void _handleError(AsyncError error) { |
+ void _handleError(error) { |
if (!closed) _controller.addError(error); |
} |
@@ -1795,7 +1795,7 @@ class _DetachedSocket extends Stream<List<int>> implements Socket { |
_DetachedSocket(this._socket, this._incoming); |
StreamSubscription<List<int>> listen(void onData(List<int> event), |
- {void onError(AsyncError error), |
+ {void onError(error), |
void onDone(), |
bool unsubscribeOnError}) { |
return _incoming.listen(onData, |
@@ -1822,7 +1822,7 @@ class _DetachedSocket extends Stream<List<int>> implements Socket { |
void add(List<int> bytes) => _socket.add(bytes); |
- void addError(AsyncError error) => _socket.addError(error); |
+ void addError(error) => _socket.addError(error); |
Future<Socket> addStream(Stream<List<int>> stream) { |
return _socket.addStream(stream); |