| Index: sdk/lib/io/http_impl.dart
|
| diff --git a/sdk/lib/io/http_impl.dart b/sdk/lib/io/http_impl.dart
|
| index 1cdcc81eacefb263663258e4d022b58b9c0e25ec..6477f3a6b1b10eaf18bccbb25e8acba8a33008f5 100644
|
| --- a/sdk/lib/io/http_impl.dart
|
| +++ b/sdk/lib/io/http_impl.dart
|
| @@ -215,7 +215,7 @@ class _HttpClientResponse
|
| if (followLoops != true) {
|
| for (var redirect in redirects) {
|
| if (redirect.location == url) {
|
| - return new Future.immediateError(
|
| + return new Future.error(
|
| new RedirectLoopException(redirects));
|
| }
|
| }
|
| @@ -282,7 +282,7 @@ class _HttpClientResponse
|
|
|
| // Fall through to here to perform normal response handling if
|
| // there is no sensible authorization handling.
|
| - return new Future.immediate(this);
|
| + return new Future.value(this);
|
| }
|
|
|
| List<String> challenge = headers[HttpHeaders.WWW_AUTHENTICATE];
|
| @@ -324,7 +324,7 @@ class _HttpClientResponse
|
| }
|
|
|
| // No credentials were found and the callback was not set.
|
| - return new Future.immediate(this);
|
| + return new Future.value(this);
|
| }
|
|
|
| Future<HttpClientResponse> _authenticateProxy() {
|
| @@ -371,7 +371,7 @@ class _HttpClientResponse
|
| }
|
|
|
| // No credentials were found and the callback was not set.
|
| - return new Future.immediate(this);
|
| + return new Future.value(this);
|
| }
|
| }
|
|
|
| @@ -509,7 +509,7 @@ abstract class _HttpOutboundMessage<T> implements IOSink {
|
| headers.contentLength = 0;
|
| } else if (!_ignoreBody && headers.contentLength > 0) {
|
| _headersSink.close().catchError((_) {});
|
| - return new Future.immediateError(new HttpException(
|
| + return new Future.error(new HttpException(
|
| "No content while contentLength was specified to be greater "
|
| " than 0: ${headers.contentLength}."));
|
| }
|
| @@ -862,7 +862,7 @@ class _HttpClientRequest extends _HttpOutboundMessage<HttpClientResponse>
|
| } else {
|
| // End with exception, too many redirects.
|
| future = response.fold(null, (x, y) {})
|
| - .then((_) => new Future.immediateError(
|
| + .then((_) => new Future.error(
|
| new RedirectLimitExceededException(response.redirects)));
|
| }
|
| } else if (response._shouldAuthenticateProxy) {
|
| @@ -870,7 +870,7 @@ class _HttpClientRequest extends _HttpOutboundMessage<HttpClientResponse>
|
| } else if (response._shouldAuthenticate) {
|
| future = response._authenticate();
|
| } else {
|
| - future = new Future<HttpClientResponse>.immediate(response);
|
| + future = new Future<HttpClientResponse>.value(response);
|
| }
|
| future.then(
|
| (v) => _responseCompleter.complete(v),
|
| @@ -1018,7 +1018,7 @@ class _HttpOutgoing implements StreamConsumer<List<int>> {
|
|
|
| Future close() {
|
| _doneCompleter.complete(_consumer);
|
| - return new Future.immediate(null);
|
| + return new Future.value();
|
| }
|
|
|
| Future get done => _doneCompleter.future;
|
| @@ -1294,7 +1294,7 @@ class _HttpClient implements HttpClient {
|
| try {
|
| proxyConf = new _ProxyConfiguration(_findProxy(uri));
|
| } catch (error, stackTrace) {
|
| - return new Future.immediateError(error, stackTrace);
|
| + return new Future.error(error, stackTrace);
|
| }
|
| }
|
| return _getConnection(uri.domain, port, proxyConf, isSecure)
|
| @@ -1360,7 +1360,7 @@ class _HttpClient implements HttpClient {
|
| Iterator<_Proxy> proxies = proxyConf.proxies.iterator;
|
|
|
| Future<_ConnnectionInfo> connect(error) {
|
| - if (!proxies.moveNext()) return new Future.immediateError(error);
|
| + if (!proxies.moveNext()) return new Future.error(error);
|
| _Proxy proxy = proxies.current;
|
| String host = proxy.isDirect ? uriHost: proxy.host;
|
| int port = proxy.isDirect ? uriPort: proxy.port;
|
| @@ -1372,7 +1372,7 @@ class _HttpClient implements HttpClient {
|
| _idleConnections.remove(key);
|
| }
|
| _activeConnections.add(connection);
|
| - return new Future.immediate(new _ConnnectionInfo(connection, proxy));
|
| + return new Future.value(new _ConnnectionInfo(connection, proxy));
|
| }
|
| return (isSecure && proxy.isDirect
|
| ? SecureSocket.connect(host,
|
|
|