| Index: sdk/lib/async/stream_pipe.dart
|
| diff --git a/sdk/lib/async/stream_pipe.dart b/sdk/lib/async/stream_pipe.dart
|
| index b126747d848bcaa84ebe0315132ecc37ff042330..7436b925dd918ec6b98988a66654827d688dc335 100644
|
| --- a/sdk/lib/async/stream_pipe.dart
|
| +++ b/sdk/lib/async/stream_pipe.dart
|
| @@ -25,10 +25,10 @@ _runUserCode(userCode(), onSuccess(value), onError(error)) {
|
| }
|
|
|
| /** Helper function to make an onError argument to [_runUserCode]. */
|
| -_cancelAndError(StreamSubscription subscription, _Future future) =>
|
| +_cancelAndError(StreamSubscription subscription, _FutureImpl future) =>
|
| (error) {
|
| subscription.cancel();
|
| - future._completeError(error);
|
| + future._setError(error);
|
| };
|
|
|
|
|
|
|