File tree Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -244,14 +244,14 @@ abstract class RunOutputTask {
244244 ready.complete ();
245245 }
246246 });
247- run.stderr
247+ final Stream < String > runStderr = run.stderr
248248 .transform <String >(utf8.decoder)
249249 .transform <String >(const LineSplitter ())
250+ .asBroadcastStream ();
251+ runStderr.listen ((String line) => print ('run:stderr: $line ' ));
252+ runStderr
250253 .skipWhile (isExpectedStderr)
251- .listen ((String line) {
252- print ('run:stderr: $line ' );
253- stderr.add (line);
254- });
254+ .listen ((String line) => stderr.add (line));
255255 unawaited (run.exitCode.then <void >((int exitCode) { runExitCode = exitCode; }));
256256 await Future .any <dynamic >(< Future <dynamic >> [ ready.future, run.exitCode ]);
257257 if (runExitCode != null ) {
You can’t perform that action at this time.
0 commit comments