Make Completers asynchronous.

tests/standalone/io/http_parser_test.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.
 
 import "package:expect/expect.dart";
 import 'dart:async';
 import 'dart:math';
 import 'dart:typed_data';
 import 'dart:isolate';
 import 'dart:uri';
@@ skipping 257 matching lines @@
 
     // Test parsing the request three times delivering the data in
     // different chunks.
     List<int> responseData = response.codeUnits;
     testWrite(responseData);
     testWrite(responseData, 10);
     testWrite(responseData, 1);
   }
 
   static void _testParseInvalidResponse(String response, [bool close = false]) {
-    _HttpParser httpParser;
-    bool errorCalled;
-    StreamController controller;
+    void testWrite(List<int> requestData, [int chunkSize = -1]) {
+      _HttpParser httpParser = new _HttpParser.responseParser();
+      StreamController controller = new StreamController();
+      bool errorCalled = false;;
 
-    void reset() {
-      httpParser = new _HttpParser.responseParser();
-      controller = new StreamController();
+      if (chunkSize == -1) chunkSize = requestData.length;
+
       var port = new ReceivePort();
       controller.stream.pipe(httpParser);
       var subscription = httpParser.listen((incoming) {
         incoming.listen(
           (data) {},
           onError: (e) {
             Expect.isFalse(errorCalled);
             errorCalled = true;
           });
       });
       subscription.onError((e) {
         Expect.isFalse(errorCalled);
         errorCalled = true;
       });
       subscription.onDone(() {
         port.close();
         Expect.isTrue(errorCalled);
       });
+
       errorCalled = false;
-    }
-
-    void testWrite(List<int> requestData, [int chunkSize = -1]) {
-      if (chunkSize == -1) chunkSize = requestData.length;
-      reset();
       for (int pos = 0;
            pos < requestData.length && !errorCalled;
            pos += chunkSize) {
         int end = min(requestData.length, pos + chunkSize);
         controller.add(requestData.sublist(pos, end));
       }
       controller.close();
     }
 
     // Test parsing the request three times delivering the data in
@@ skipping 552 matching lines @@
 0123456789012345678901234567890\r
 0\r\n\r\n""";
     _testParseInvalidResponse(response);
   }
 }
 
 
 void main() {
   HttpParserTest.runAllTests();
 }