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

tests/standalone/io/http_advanced_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.
 //
 // VMOptions=
 // VMOptions=--short_socket_read
 // VMOptions=--short_socket_write
 // VMOptions=--short_socket_read --short_socket_write
 
 #import("dart:isolate");
@@ skipping 269 matching lines @@
       request.headers.set("Host", "www.dartlang.org:");
       Expect.equals("www.dartlang.org", request.headers.host);
       Expect.equals(HttpClient.DEFAULT_HTTP_PORT, request.headers.port);
       request.headers.set("Host", "www.dartlang.org:1234");
       Expect.equals("www.dartlang.org", request.headers.host);
       Expect.equals(1234, request.headers.port);
       request.outputStream.close();
     };
     conn.onResponse = (HttpClientResponse response) {
       Expect.equals(HttpStatus.OK, response.statusCode);
-      httpClient.shutdown();
-      testServerMain.shutdown();
-      completer.complete(true);
+      response.inputStream.onData = response.inputStream.read;
+      response.inputStream.onClosed = () {
+        httpClient.shutdown();
+        testServerMain.shutdown();
+        completer.complete(true);
+      };
     };
   });
   testServerMain.start();
   return completer.future;
 }
 
 Future testExpires() {
   Completer completer = new Completer();
   TestServerMain testServerMain = new TestServerMain();
   testServerMain.setServerStartedHandler((int port) {
     int responses = 0;
     HttpClient httpClient = new HttpClient();
 
     void processResponse(HttpClientResponse response) {
       Expect.equals(HttpStatus.OK, response.statusCode);
       Expect.equals("Fri, 11 Jun 1999 18:46:53 GMT",
                     response.headers["expires"][0]);
       Expect.equals(new Date.utc(1999, Date.JUN, 11, 18, 46, 53, 0),
                     response.headers.expires);
-      responses++;
-      if (responses == 2) {
-        httpClient.shutdown();
-        testServerMain.shutdown();
-        completer.complete(true);
-      }
+      response.inputStream.onData = response.inputStream.read;
+      response.inputStream.onClosed = () {
+        responses++;
+        if (responses == 2) {
+          httpClient.shutdown();
+          testServerMain.shutdown();
+          completer.complete(true);
+        }
+      };
     }
 
     HttpClientConnection conn1 = httpClient.get("127.0.0.1", port, "/expires1");
     conn1.onResponse = (HttpClientResponse response) {
       processResponse(response);
     };
     HttpClientConnection conn2 = httpClient.get("127.0.0.1", port, "/expires2");
     conn2.onResponse = (HttpClientResponse response) {
       processResponse(response);
     };
@@ skipping 11 matching lines @@
 
     void processResponse(HttpClientResponse response) {
       Expect.equals(HttpStatus.OK, response.statusCode);
       Expect.equals("text/html; charset=utf-8",
                     response.headers.contentType.toString());
       Expect.equals("text/html", response.headers.contentType.value);
       Expect.equals("text", response.headers.contentType.primaryType);
       Expect.equals("html", response.headers.contentType.subType);
       Expect.equals("utf-8",
                     response.headers.contentType.parameters["charset"]);
-      responses++;
-      if (responses == 2) {
-        httpClient.shutdown();
-        testServerMain.shutdown();
-        completer.complete(true);
-      }
+      response.inputStream.onData = response.inputStream.read;
+      response.inputStream.onClosed = () {
+        responses++;
+        if (responses == 2) {
+          httpClient.shutdown();
+          testServerMain.shutdown();
+          completer.complete(true);
+        }
+      };
     }
 
     HttpClientConnection conn1 =
         httpClient.get("127.0.0.1", port, "/contenttype1");
     conn1.onRequest = (HttpClientRequest request) {
       ContentType contentType = new ContentType();
       contentType.value = "text/html";
       contentType.parameters["charset"] = "utf-8";
       request.headers.contentType = contentType;
       request.outputStream.close();
@@ skipping 43 matching lines @@
           Expect.fail("Unexpected cookie");
         }
       });
       HttpClientConnection conn2 =
           httpClient.get("127.0.0.1", port, "/cookie2");
       conn2.onRequest = (HttpClientRequest request) {
         request.cookies.add(response.cookies[0]);
         request.cookies.add(response.cookies[1]);
         request.outputStream.close();
       };
-      conn2.onResponse = (HttpClientResponse ignored) {
-        httpClient.shutdown();
-        testServerMain.shutdown();
-        completer.complete(true);
+      conn2.onResponse = (HttpClientResponse response) {
+        response.inputStream.onData = response.inputStream.read;
+        response.inputStream.onClosed = () {
+          httpClient.shutdown();
+          testServerMain.shutdown();
+          completer.complete(true);
+        };
       };
     };
   });
   testServerMain.start();
   return completer.future;
 }
 
 Future testFlush() {
   Completer completer = new Completer();
   TestServerMain testServerMain = new TestServerMain();
   testServerMain.setServerStartedHandler((int port) {
     HttpClient httpClient = new HttpClient();
 
     HttpClientConnection conn = httpClient.get("127.0.0.1", port, "/flush");
     conn.onRequest = (HttpClientRequest request) {
       request.outputStream.flush();
       request.outputStream.close();
     };
     conn.onResponse = (HttpClientResponse response) {
       Expect.equals(HttpStatus.OK, response.statusCode);
-      httpClient.shutdown();
-      testServerMain.shutdown();
-      completer.complete(true);
+      response.inputStream.onData = response.inputStream.read;
+      response.inputStream.onClosed = () {
+        httpClient.shutdown();
+        testServerMain.shutdown();
+        completer.complete(true);
+      };
     };
   });
   testServerMain.start();
   return completer.future;
 }
 
 void main() {
   print('testHost()');
   testHost().chain((_) {
   print('testExpires()');
     return testExpires().chain((_) {
       print('testContentType()');
       return testContentType().chain((_) {
         print('testCookies()');
         return testCookies().chain((_) {
           print('testFlush()');
           return testFlush();
         });
       });
     });
   }).then((_) {
     print('done');
   });
 }