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 {
244
244
ready.complete ();
245
245
}
246
246
});
247
- run.stderr
247
+ final Stream < String > runStderr = run.stderr
248
248
.transform <String >(utf8.decoder)
249
249
.transform <String >(const LineSplitter ())
250
+ .asBroadcastStream ();
251
+ runStderr.listen ((String line) => print ('run:stderr: $line ' ));
252
+ runStderr
250
253
.skipWhile (isExpectedStderr)
251
- .listen ((String line) {
252
- print ('run:stderr: $line ' );
253
- stderr.add (line);
254
- });
254
+ .listen ((String line) => stderr.add (line));
255
255
unawaited (run.exitCode.then <void >((int exitCode) { runExitCode = exitCode; }));
256
256
await Future .any <dynamic >(< Future <dynamic >> [ ready.future, run.exitCode ]);
257
257
if (runExitCode != null ) {
You can’t perform that action at this time.
0 commit comments