Add close to input stream and cleanup socket and streams

runtime/bin/stream_util.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 _BaseDataInputStream {
   abstract int available();
 
   List<int> read([int len]) {
     if (_closeCallbackCalled) return null;
     int bytesToRead = available();
@@ skipping 17 matching lines @@
     if (offset < 0) throw new StreamException("Illegal offset $offset");
     if (len < 0) throw new StreamException("Illegal length $len");
     int bytesToRead = Math.min(len, available());
     return _readInto(buffer, offset, bytesToRead);
   }
 
   void pipe(OutputStream output, [bool close = true]) {
     _pipe(this, output, close: close);
   }
 
+  void close() {
+    if (_scheduledDataCallback != null) _scheduledDataCallback.cancel();
+    _close();
+    _checkScheduleCallbacks();
+  }
+
   bool get closed() => _closeCallbackCalled;
 
   void set dataHandler(void callback()) {
     _clientDataHandler = callback;
     _checkScheduleCallbacks();
   }
 
   void set closeHandler(void callback()) {
     _clientCloseHandler = callback;
     _checkScheduleCallbacks();
@@ skipping 78 matching lines @@
     input.dataHandler = pipeDataHandler;
     output.noPendingWriteHandler = null;
   };
 
   _inputCloseHandler = input._clientCloseHandler;
   input.dataHandler = pipeDataHandler;
   input.closeHandler = pipeCloseHandler;
   output.noPendingWriteHandler = null;
 }