Add pipe to input stream

runtime/bin/socket_stream.dart

 // Copyright (c) 2011, 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.
 
 class SocketInputStream implements InputStream {
   SocketInputStream(Socket socket) : _socket = socket;
 
   List<int> read([int len]) {
     int bytesToRead = available();
     if (bytesToRead == 0) return null;
@@ skipping 18 matching lines @@
   int readInto(List<int> buffer, int offset, int len) {
     if (offset === null) offset = 0;
     if (len === null) len = buffer.length;
     if (offset < 0) throw new StreamException("Illegal offset $offset");
     if (len < 0) throw new StreamException("Illegal length $len");
     return _socket.readList(buffer, offset, len);
   }
 
   int available() => _socket.available();
 
+  void pipe(OutputStream output, [bool close = true]) {
+    _pipe(this, output, close: close);
+  }
+
   void set dataHandler(void callback()) {
     _socket.dataHandler = callback;
   }
 
   void set closeHandler(void callback()) {
+    _clientCloseHandler = callback;
     _socket.closeHandler = callback;
   }
 
   void set errorHandler(void callback()) {
     _socket.errorHandler = callback;
   }
 
   Socket _socket;
+  Function _clientCloseHandler;
 }
 
 
 class SocketOutputStream implements OutputStream {
   SocketOutputStream(Socket socket)
       : _socket = socket, _pendingWrites = new _BufferList();
 
   bool write(List<int> buffer, [bool copyBuffer = true]) {
     return _write(buffer, 0, buffer.length, copyBuffer);
   }
@@ skipping 95 matching lines @@
     if (_streamErrorHandler != null) _streamErrorHandler();
   }
 
   Socket _socket;
   _BufferList _pendingWrites;
   var _noPendingWriteHandler;
   var _streamErrorHandler;
   bool _closing = false;
   bool _closed = false;
 }