Remove explicit delayed futures in dart:io.

sdk/lib/io/http_parser.dart

 // Copyright (c) 2013, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 part of dart.io;
 
 // Global constants.
 class _Const {
   // Bytes for "HTTP".
   static const HTTP = const [72, 84, 84, 80];
@@ skipping 87 matching lines @@
 class _HttpDetachedIncoming extends Stream<List<int>> {
   StreamController<List<int>> controller;
   final StreamSubscription subscription;
 
   List<int> carryOverData;
   bool paused;
 
   Completer resumeCompleter;
 
   _HttpDetachedIncoming(StreamSubscription this.subscription,
-                        List<int> this.carryOverData,
-                        Completer oldResumeCompleter) {
+                        List<int> this.carryOverData) {
     controller = new StreamController<List<int>>(
         onListen: resume,
         onPause: pause,
         onResume: resume,
         onCancel: () => subscription.cancel());
     if (subscription == null) {
       // Socket was already closed.
       if (carryOverData != null) controller.add(carryOverData);
       controller.close();
     } else {
       pause();
-      if (oldResumeCompleter != null) oldResumeCompleter.complete();
       subscription.resume();
       subscription.onData(controller.add);
       subscription.onDone(controller.close);
       subscription.onError(controller.addError);
     }
   }
 
   StreamSubscription<List<int>> listen(void onData(List<int> event),
                                        {void onError(error),
                                         void onDone(),
@@ skipping 653 matching lines @@
   }
 
   int get messageType => _messageType;
   int get transferLength => _transferLength;
   bool get upgrade => _connectionUpgrade && _state == _State.UPGRADED;
   bool get persistentConnection => _persistentConnection;
 
   void set responseToMethod(String method) { _responseToMethod = method; }
 
   _HttpDetachedIncoming detachIncoming() {
-    var completer = _pauseCompleter;
-    _pauseCompleter = null;
     return new _HttpDetachedIncoming(_socketSubscription,
-                                     readUnparsedData(),
-                                     completer);
+                                     readUnparsedData());
   }
 
   List<int> readUnparsedData() {
     if (_buffer == null) return null;
     if (_index == _buffer.length) return null;
     var result = _buffer.sublist(_index);
     _releaseBuffer();
     return result;
   }
 
@@ skipping 176 matching lines @@
   String _responseToMethod;  // Indicates the method used for the request.
   int _remainingContent;
 
   _HttpHeaders _headers;
 
   // The current incoming connection.
   _HttpIncoming _incoming;
   StreamSubscription _socketSubscription;
   bool _paused = true;
   bool _bodyPaused = false;
-  Completer _pauseCompleter;
   StreamController<_HttpIncoming> _controller;
   StreamController<List<int>> _bodyController;
 }
 
 
 class HttpParserException implements Exception {
   const HttpParserException([String this.message = ""]);
   String toString() => "HttpParserException: $message";
   final String message;
 }