StreamConsumer has an addStream and a close functions.

sdk/lib/io/http_parser.dart

Index: sdk/lib/io/http_parser.dart
diff --git a/sdk/lib/io/http_parser.dart b/sdk/lib/io/http_parser.dart
index 047f37a513dc792b356ea093c5190be602cd1fc3..7d098d02a8e0d2e4a56eb5042e04f9fbbd3a376d 100644
--- a/sdk/lib/io/http_parser.dart
+++ b/sdk/lib/io/http_parser.dart
@@ -242,6 +242,14 @@ class _HttpParser
     return completer.future;
   }
 
+  Future<_HttpParser> addStream(Stream<List<int>> stream) {
+    throw new UnimplementedError("_HttpParser.addStream");
+  }
+
+  Future<_HttpParser> close() {
+    throw new UnimplementedError("_HttpParser.close");
+  }
+
   // From RFC 2616.
   // generic-message = start-line
   //                   *(message-header CRLF)