Update pkg/http to use the new async APIs.

pkg/http/test/request_test.dart

Index: pkg/http/test/request_test.dart
diff --git a/pkg/http/test/request_test.dart b/pkg/http/test/request_test.dart
index 14b596bb658257cd6e5e22d72df57182bc5ce267..843cdabb40470a9b81149167352d323a3cd76f26 100644
--- a/pkg/http/test/request_test.dart
+++ b/pkg/http/test/request_test.dart
@@ -17,15 +17,11 @@ void main() {
 
     var request = new http.Request('POST', serverUrl);
     request.body = "hello";
-    var future = request.send().then((response) {
-      expect(response.statusCode, equals(200));
-      return consumeInputStream(response.stream);
-    }).then((bytes) => new String.fromCharCodes(bytes));
-    future.catchError((_) {}).then(expectAsync1((_) {
-      stopServer();
-    }));
 
-    expect(future, completion(parse(equals({
+    expect(request.send().then((response) {

[Bob Nystrom, 2013/01/08 23:50:49]

I think you'll need guardAsync here.

[nweiz, 2013/01/09 00:52:11]

See previous comment.

+      expect(response.statusCode, equals(200));
+      return response.stream.bytesToString();
+    }).whenComplete(stopServer), completion(parse(equals({

[Bob Nystrom, 2013/01/08 23:50:49]

And maybe even here around stopServer.

[nweiz, 2013/01/09 00:52:11]

See previous² comment.

       'method': 'POST',
       'path': '/',
       'headers': {
@@ -316,9 +312,7 @@ void main() {
     test('returns a stream that emits the request body', () {
       var request = new http.Request('POST', dummyUrl);
       request.body = "Hello, world!";
-      expect(
-          consumeInputStream(request.finalize())
-              .then((bytes) => new String.fromCharCodes(bytes)),
+      expect(request.finalize().bytesToString(),
           completion(equals("Hello, world!")));
     });