| Index: pkg/http/lib/src/utils.dart
|
| diff --git a/pkg/http/lib/src/utils.dart b/pkg/http/lib/src/utils.dart
|
| index 65c47997b1e6991c5cf460fe4ae8659432901262..51b209790903c240bec212a455ea4b1e91129ef2 100644
|
| --- a/pkg/http/lib/src/utils.dart
|
| +++ b/pkg/http/lib/src/utils.dart
|
| @@ -152,10 +152,10 @@ Stream onDone(Stream stream, void onDone()) {
|
| // TODO(nweiz): remove this when issue 7786 is fixed.
|
| /// Pipes all data and errors from [stream] into [sink]. When [stream] is done,
|
| /// [sink] is closed and the returned [Future] is completed.
|
| -Future store(Stream stream, StreamSink sink) {
|
| +Future store(Stream stream, EventSink sink) {
|
| var completer = new Completer();
|
| stream.listen(sink.add,
|
| - onError: sink.signalError,
|
| + onError: sink.addError,
|
| onDone: () {
|
| sink.close();
|
| completer.complete();
|
| @@ -166,10 +166,10 @@ Future store(Stream stream, StreamSink sink) {
|
| /// Pipes all data and errors from [stream] into [sink]. Completes [Future] once
|
| /// [stream] is done. Unlike [store], [sink] remains open after [stream] is
|
| /// done.
|
| -Future writeStreamToSink(Stream stream, StreamSink sink) {
|
| +Future writeStreamToSink(Stream stream, EventSink sink) {
|
| var completer = new Completer();
|
| stream.listen(sink.add,
|
| - onError: sink.signalError,
|
| + onError: sink.addError,
|
| onDone: () => completer.complete());
|
| return completer.future;
|
| }
|
| @@ -200,8 +200,8 @@ Pair<Stream, Stream> tee(Stream stream) {
|
| controller1.add(value);
|
| controller2.add(value);
|
| }, onError: (error) {
|
| - controller1.signalError(error);
|
| - controller2.signalError(error);
|
| + controller1.addError(error);
|
| + controller2.addError(error);
|
| }, onDone: () {
|
| controller1.close();
|
| controller2.close();
|
|
|