Update pkg/http to use the new async APIs.

pkg/http/test/mock_client_test.dart

 // Copyright (c) 2012, 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.
 
 library mock_client_test;
 
 import 'dart:async';
 import 'dart:io';
 import 'dart:json' as json;
 import 'dart:uri';
@@ skipping 16 matching lines @@
       'field1': 'value1',
       'field2': 'value2'
     }).then((response) => response.body), completion(parse(equals({
       'field1': 'value1',
       'field2': 'value2'
     }))));
   });
 
   test('handles a streamed request', () {
     var client = new MockClient.streaming((request, bodyStream) {
-      return consumeInputStream(bodyStream).then((body) {
-        var stream = new ListInputStream();
+      return bodyStream.bytesToString().then((bodyString) {
+        var stream = new StreamController<List<int>>.singleSubscription();
         async.then((_) {
-          var bodyString = new String.fromCharCodes(body);
-          stream.write('Request body was "$bodyString"'.charCodes);
-          stream.markEndOfStream();
+          stream.add('Request body was "$bodyString"'.charCodes);
+          stream.close();
         });
 
         return new http.StreamedResponse(stream, 200, -1);
       });
     });
 
     var uri = new Uri.fromString("http://example.com/foo");
     var request = new http.Request("POST", uri);
     request.body = "hello, world";
     var future = client.send(request)
         .then(http.Response.fromStream)
         .then((response) => response.body);
     expect(future, completion(equals('Request body was "hello, world"')));
   });
 
   test('handles a request with no body', () {
     var client = new MockClient((request) {
       return new Future.immediate(new http.Response('you did it', 200));
     });
 
     expect(client.read("http://example.com/foo"),
         completion(equals('you did it')));
   });
 }