Generate an error for active connections when the HTTP client is shutdown

tests/standalone/io/http_auth_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.
 
 #import("dart:isolate");
 #import("dart:crypto");
 #import("dart:io");
 #import("dart:uri");
 #import("dart:utf");
 
@@ skipping 62 matching lines @@
 
 void testUrlUserInfo() {
   Server server = setupServer();
   HttpClient client = new HttpClient();
 
   HttpClientConnection conn =
       client.getUrl(
           new Uri.fromString(
               "http://username:password@127.0.0.1:${server.port}/"));
   conn.onResponse = (HttpClientResponse response) {
-    server.shutdown();
-    client.shutdown();
+    response.inputStream.onData = response.inputStream.read;
+    response.inputStream.onClosed = () {
+      server.shutdown();
+      client.shutdown();
+    };
   };
 }
 
 void testBasicNoCredentials() {
   Server server = setupServer();
   HttpClient client = new HttpClient();
 
   Future makeRequest(Uri url) {
     Completer completer = new Completer();
     HttpClientConnection conn = client.getUrl(url);
     conn.onResponse = (HttpClientResponse response) {
       Expect.equals(HttpStatus.UNAUTHORIZED, response.statusCode);
-      completer.complete(null);
+      response.inputStream.onData = response.inputStream.read;
+      response.inputStream.onClosed = () => completer.complete(null);
     };
     return completer.future;
   }
 
   var futures = [];
   for (int i = 0; i < 5; i++) {
     futures.add(
         makeRequest(
             new Uri.fromString("http://127.0.0.1:${server.port}/test$i")));
     futures.add(
         makeRequest(
             new Uri.fromString("http://127.0.0.1:${server.port}/test$i/xxx")));
   }
   Futures.wait(futures).then((_) {
     server.shutdown();
     client.shutdown();
   });
 }
 
 void testBasicCredentials() {
   Server server = setupServer();
   HttpClient client = new HttpClient();
 
   Future makeRequest(Uri url) {
     Completer completer = new Completer();
     HttpClientConnection conn = client.getUrl(url);
     conn.onResponse = (HttpClientResponse response) {
       Expect.equals(HttpStatus.OK, response.statusCode);
-      completer.complete(null);
+      response.inputStream.onData = response.inputStream.read;
+      response.inputStream.onClosed = () => completer.complete(null);
     };
     return completer.future;
   }
 
   for (int i = 0; i < 5; i++) {
     client.addCredentials(
         new Uri.fromString("http://127.0.0.1:${server.port}/test$i"),
         "realm",
         new HttpClientBasicCredentials("test$i", "test$i"));
   }
@@ skipping 31 matching lines @@
       completer.complete(true);
     });
     return completer.future;
   };
 
   Future makeRequest(Uri url) {
     Completer completer = new Completer();
     HttpClientConnection conn = client.getUrl(url);
     conn.onResponse = (HttpClientResponse response) {
       Expect.equals(HttpStatus.OK, response.statusCode);
-      completer.complete(null);
+      response.inputStream.onData = response.inputStream.read;
+      response.inputStream.onClosed = () => completer.complete(null);
     };
     return completer.future;
   }
 
   List<Future> makeRequests() {
     var futures = [];
     for (int i = 0; i < 5; i++) {
       futures.add(
           makeRequest(
               new Uri.fromString("http://127.0.0.1:${server.port}/test$i")));
@@ skipping 66 matching lines @@
 main() {
   testUrlUserInfo();
   testBasicNoCredentials();
   testBasicCredentials();
   testBasicAuthenticateCallback();
   // These teste are not normally run. They can be used for locally
   // testing with another web server (e.g. Apache).
   //testLocalServerBasic();
   //testLocalServerDigest();
 }