Implement addStream for HttpClientRequest/HttpResponse and propegate all write-errors from the sock…

tests/standalone/io/http_shutdown_test.dart

 // Copyright (c) 2013, 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:async";
@@ skipping 35 matching lines @@
 
     int count = 0;
     HttpClient client = new HttpClient();
     for (int i = 0; i < totalConnections; i++) {
       client.get("127.0.0.1", server.port, "/")
         .then((HttpClientRequest request) {
           request.contentLength = -1;
           for (int i = 0; i < outputStreamWrites; i++) {
             request.addString("Hello, world!");
           }
+          request.done.catchError((_) {});

[Søren Gjesse, 2013/02/27 15:07:43]

I think we should add default handling of this so that if there is no error
handler on the done future something default will happen. Developers will forget
this and there HTTP servers will crash. Not for this CL, but lets think about
it.

[Anders Johnsen, 2013/02/28 11:39:02]

Yes, we need to decide on what should happen on this one. Let's discuss offline
for another CL.

           return request.close();
         })
         .then((HttpClientResponse response) {
           response.listen(
             (_) {},
             onDone: () {
               count++;
               if (count == totalConnections) {
                 client.close(force: true);
                 server.close();
@@ skipping 77 matching lines @@
 
 
 void test5(int totalConnections) {
   HttpServer.bind().then((server) {
     server.listen(
         (request) {
           request.listen(
               (_) { },
               onDone: () {
                 request.response.close();
+                request.response.done.catchError((e) {});
               },
               onError: (error) { });
         },
         onError: (error) { });
 
     // Create a number of client requests and keep then active. Then
     // close the client and wait for the server to lose all active
     // connections.
     var client= new HttpClient();
     for (int i = 0; i < totalConnections; i++) {
       client.post("127.0.0.1", server.port, "/")
         .then((request) {
             request.add([0]);
             // TODO(sgjesse): Make this test work with
             //request.response instead of request.close() return
             //return request.response;
+            request.done.catchError((e) {});
             return request.close();
           })
         .then((response) { })
         .catchError((e) { }, test: (e) => e is HttpParserException);
     }
     bool clientClosed = false;
     new Timer.repeating(new Duration(milliseconds: 100), (timer) {
       if (!clientClosed) {
         if (server.connectionsInfo().total == totalConnections) {
           clientClosed = true;
@@ skipping 15 matching lines @@
   test1(10);
   test2(1, 10);
   test2(10, 10);
   test2(10, 1000);
   test3(1);
   test3(10);
   test4();
   test5(1);
   test5(10);
 }