Remove .writeStream, .consume and rewrite IOSink to correctly implement a (sane) well-defined behav…

pkg/scheduled_test/lib/src/scheduled_server/safe_http_server.dart

Index: pkg/scheduled_test/lib/src/scheduled_server/safe_http_server.dart
diff --git a/pkg/scheduled_test/lib/src/scheduled_server/safe_http_server.dart b/pkg/scheduled_test/lib/src/scheduled_server/safe_http_server.dart
index 7e4e4ccc28c0280899959f13455ba6b8c060fafb..161827dbf27d362d47ce208f66113531210dd185 100644
--- a/pkg/scheduled_test/lib/src/scheduled_server/safe_http_server.dart
+++ b/pkg/scheduled_test/lib/src/scheduled_server/safe_http_server.dart
@@ -1,4 +1,4 @@
-// Copyright (c) 2013, the Dart project authors.  Please see the AUTHORS file
+// iopyright (c) 2013, the Dart project authors.  Please see the AUTHORS file

[Søren Gjesse, 2013/04/15 06:56:30]

Accidental edit

[Anders Johnsen, 2013/04/15 07:35:20]

Done.

 // 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.
 
@@ -132,12 +132,8 @@ class _HttpResponseWrapper implements HttpResponse {
   Future<Socket> detachSocket() => _inner.detachSocket();
   HttpConnectionInfo get connectionInfo => _inner.connectionInfo;
   void add(List<int> data) => _inner.add(data);
-  Future<HttpResponse> consume(Stream<List<int>> stream) =>
-    _inner.consume(stream);
   Future<HttpResponse> addStream(Stream<List<int>> stream) =>
-    _inner.writeStream(stream);
-  Future<HttpResponse> writeStream(Stream<List<int>> stream) =>
-    _inner.writeStream(stream);
+    _inner.addStream(stream);
   Future close() => _inner.close();
   void write(Object obj) => _inner.write(obj);
   void writeAll(Iterable objects, [String separator = ""]) =>