Chromium Code Reviews| Index: utils/pub/io.dart |
| diff --git a/utils/pub/io.dart b/utils/pub/io.dart |
| index 0c30c885dbb85046ad2d7999ee172b869224e213..dc779f5595d632b726d341670f78a81a4a9bd2eb 100644 |
| --- a/utils/pub/io.dart |
| +++ b/utils/pub/io.dart |
| @@ -619,7 +619,9 @@ Future pipeInputToInput(InputStream source, ListInputStream sink) { |
| sink.markEndOfStream(); |
| completer.complete(null); |
| }; |
| - source.onData = () => sink.write(source.read()); |
| + source.onData = () { |
| + if (!sink.closed) sink.write(source.read()); |
|
Bob Nystrom
2012/12/08 03:35:33
Should do the read() even if it's closed.
Also, m
nweiz
2012/12/08 03:38:04
I think it's more or less "business as usual" for
|
| + }; |
| // TODO(nweiz): propagate this error to the sink. See issue 3657. |
| source.onError = (e) { throw e; }; |
| return completer.future; |