Use the dart:async Stream API thoroughly in Pub.

utils/tests/pub/pub_uploader_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 pub_uploader_test;
 
 import 'dart:io';
 import 'dart:json' as json;
 
 import 'test_pub.dart';
@@ skipping 36 matching lines @@
           output: USAGE_STRING, exitCode: 64);
     });
   });
 
   integration('adds an uploader', () {
     var server = new ScheduledServer();
     credentialsFile(server, 'access token').scheduleCreate();
     var pub = startPubUploader(server, ['--package', 'pkg', 'add', 'email']);
 
     server.handle('POST', '/packages/pkg/uploaders.json', (request, response) {
-      expect(consumeInputStream(request.inputStream).then((bodyBytes) {
+      expect(wrapInputStream(request.inputStream).toBytes().then((bodyBytes) {
         expect(new String.fromCharCodes(bodyBytes), equals('email=email'));
 
         response.headers.contentType = new ContentType("application", "json");
         response.outputStream.writeString(json.stringify({
           'success': {'message': 'Good job!'}
         }));
         response.outputStream.close();
       }), completes);
     });
 
@@ skipping 101 matching lines @@
         (request, response) {
       response.outputStream.writeString("{not json");
       response.outputStream.close();
     });
 
     expectLater(pub.nextErrLine(), equals('Invalid server response:'));
     expectLater(pub.nextErrLine(), equals('{not json'));
     pub.shouldExit(1);
   });
 }