Use the dart:async Stream API thoroughly in Pub.

utils/tests/pub/curl_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 curl_client_test;
 
 import 'dart:io';
 import 'dart:isolate';
 import 'dart:json' as json;
 import 'dart:uri';
@@ skipping 69 matching lines @@
 
   _server.addRequestHandler((request) => request.path == '/redirect',
       (request, response) {
     response.statusCode = 302;
     response.headers.set('location', serverUrl.resolve('/').toString());
     response.contentLength = 0;
     response.outputStream.close();
   });
 
   _server.defaultRequestHandler = (request, response) {
-    consumeInputStream(request.inputStream).then((requestBodyBytes) {
+    wrapInputStream(request.inputStream).toBytes().then((requestBodyBytes) {
       response.statusCode = 200;
       response.headers.contentType = new ContentType("application", "json");
 
       var requestBody;
       if (requestBodyBytes.isEmpty) {
         requestBody = null;
       } else if (request.headers.contentType.charset != null) {
         var encoding = requiredEncodingForCharset(
             request.headers.contentType.charset);
         requestBody = decodeString(requestBodyBytes, encoding);
@@ skipping 350 matching lines @@
   test('without following redirects', () {
     var request = new http.Request('GET', serverUrl.resolve('/redirect'));
     request.followRedirects = false;
     expect(new CurlClient().send(request).then(http.Response.fromStream)
         .then((response) {
       expect(response.statusCode, equals(302));
       expect(response.isRedirect, true);
     }), completes);
   });
 }