Add close to input stream and cleanup socket and streams

runtime/bin/stream_util.dart

Index: runtime/bin/stream_util.dart
diff --git a/runtime/bin/stream_util.dart b/runtime/bin/stream_util.dart
index 48039e1e92debc47052e769203ea5af39b5809c4..9175cce246badbede9a431c68fd9ce23011c7522 100644
--- a/runtime/bin/stream_util.dart
+++ b/runtime/bin/stream_util.dart
@@ -35,6 +35,12 @@ class _BaseDataInputStream {
     _pipe(this, output, close: close);
   }
 
+  void close() {
+    if (_scheduledDataCallback != null) _scheduledDataCallback.cancel();
+    _close();
+    _checkScheduleCallbacks();
+  }
+
   bool get closed() => _closeCallbackCalled;
 
   void set dataHandler(void callback()) {