StreamConsumer has an addStream and a close functions.

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([String address = "127.0.0.1",
                                                    int port = 0,
                                                    int backlog = 0]) {
     return _RawServerSocket.bind(address, port, backlog);
   }
@@ skipping 671 matching lines @@
             socket._consumerDone(error);
           },
           onDone: () {
             socket._consumerDone();
           },
           unsubscribeOnError: true);
     }
     return socket._doneFuture;
   }
 
+  Future<Socket> addStream(Stream<List<int>> stream) {
+    Completer completer = new Completer<Socket>();
+    if (socket._raw != null) {
+      subscription = stream.listen(
+          (data) {
+            assert(!paused);
+            assert(buffer == null);
+            buffer = data;
+            offset = 0;
+            write();
+          },
+          onError: (error) {
+            socket._consumerDone(error);
+            completer.completeError(error.error, error.stackTrace);
+          },
+          onDone: () {
+            completer.complete(socket);
+          },
+          unsubscribeOnError: true);
+    }
+    return completer.future;
+  }
+
+  Future<Socket> close() {
+    socket._consumerDone();
+    return completer.future;
+  }
+
   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;
           // TODO(ajohnsen): It would be nice to avoid this check.
@@ skipping 243 matching lines @@
     _raw.onBadCertificate = callback;
   }
 
   X509Certificate get peerCertificate {
     if (_raw == null) {
      throw new StateError("peerCertificate called on destroyed SecureSocket");
     }
     return _raw.peerCertificate;
   }
 }