Merge all http-outgoing transfomers into _HttpOutgoing, including simpler(better) buffering.

runtime/bin/socket_patch.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.
 
 patch class RawServerSocket {
   /* patch */ static Future<RawServerSocket> bind(address,
                                                   int port,
                                                   {int backlog: 0,
                                                    bool v6Only: false}) {
     return _RawServerSocket.bind(address, port, backlog, v6Only);
@@ skipping 1161 matching lines @@
   Future<Socket> addStream(Stream<List<int>> stream) {
     socket._ensureRawSocketSubscription();
     streamCompleter = new Completer<Socket>();
     if (socket._raw != null) {
       subscription = stream.listen(
           (data) {
             assert(!paused);
             assert(buffer == null);
             buffer = data;
             offset = 0;
-            write();
+            try {
+              write();
+            } catch (e) {
+              stop();
+              socket._consumerDone();
+              done(e);
+            }
           },
           onError: (error, [stackTrace]) {
             socket._consumerDone();
             done(error, stackTrace);
           },
           onDone: () {
             done();
           },
           cancelOnError: true);
     }
     return streamCompleter.future;
   }
 
   Future<Socket> close() {
     socket._consumerDone();
     return new Future.value(socket);
   }
 
   void write() {
-    try {
-      if (subscription == null) return;
-      assert(buffer != null);
-      // Write as much as possible.
-      offset += socket._write(buffer, offset, buffer.length - offset);
-      if (offset < buffer.length) {
-        if (!paused) {
-          paused = true;
-          subscription.pause();
-        }
-        socket._enableWriteEvent();
-      } else {
-        buffer = null;
-        if (paused) {
-          paused = false;
-          subscription.resume();
-        }
+    if (subscription == null) return;
+    assert(buffer != null);
+    // Write as much as possible.
+    offset += socket._write(buffer, offset, buffer.length - offset);
+    if (offset < buffer.length) {
+      if (!paused) {
+        paused = true;
+        subscription.pause();
       }
-    } catch (e) {
-      stop();
-      socket._consumerDone();
-      done(e);
+      socket._enableWriteEvent();
+    } else {
+      buffer = null;
+      if (paused) {
+        paused = false;
+        subscription.resume();
+      }
     }
   }
 
   void done([error, stackTrace]) {
     if (streamCompleter != null) {
       if (error != null) {
         streamCompleter.completeError(error, stackTrace);
       } else {
         streamCompleter.complete(socket);
       }
@@ skipping 355 matching lines @@
 
 Datagram _makeDatagram(List<int> data,
                        String address,
                        List<int> in_addr,
                        int port) {
   return new Datagram(
       data,
       new _InternetAddress(address, null, in_addr),
       port);
 }