Index: sdk/lib/async/stream.dart |
diff --git a/sdk/lib/async/stream.dart b/sdk/lib/async/stream.dart |
index e163607208f159ac183e3193f06d38414a587090..34c884aa5609110c1b5939e6141e8385285135ee 100644 |
--- a/sdk/lib/async/stream.dart |
+++ b/sdk/lib/async/stream.dart |
@@ -237,9 +237,7 @@ abstract class Stream<T> { |
* Binds this stream as the input of the provided [StreamConsumer]. |
*/ |
Future pipe(StreamConsumer<T> streamConsumer) { |
- // TODO(floitsch): switch to: |
- // streamConsumer.addStream(this).then((_) => streamConsumer.close()); |
- return streamConsumer.consume(this); |
+ return streamConsumer.addStream(this).then((_) => streamConsumer.close()); |
} |
/** |
@@ -891,12 +889,6 @@ class _EventSinkView<T> extends EventSink<T> { |
abstract class StreamConsumer<S> { |
Future addStream(Stream<S> stream); |
Future close(); |
- |
- |
- /** |
- * Consume is deprecated. Use [addStream] followed by [close] instead. |
- */ |
- Future consume(Stream<S> stream); |
} |