Index: pkg/http/test/utils.dart |
diff --git a/pkg/http/test/utils.dart b/pkg/http/test/utils.dart |
index 9e9ae8b3408d37c5ab724bd4f8486fe0f41f3f18..53ff769bbf68a1a16a3a2ab3250cbbf85e75e074 100644 |
--- a/pkg/http/test/utils.dart |
+++ b/pkg/http/test/utils.dart |
@@ -4,6 +4,7 @@ |
library test_utils; |
+import 'dart:async'; |
import 'dart:io'; |
import 'dart:json' as json; |
import 'dart:uri'; |
@@ -104,6 +105,11 @@ void stopServer() { |
_server = null; |
} |
+// TODO(nweiz): remove this once issue 7785 is fixed. |
+/// Buffers all input from an InputStream and returns it as a future. |
+Future<List<int>> consumeInputStream(InputStream stream) => |
+ new http.ByteStream(wrapInputStream(stream)).toBytes(); |
+ |
/// A matcher that matches JSON that parses to a value that matches the inner |
/// matcher. |
Matcher parse(matcher) => new _Parse(matcher); |