We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c7cb5f3 commit 7336312Copy full SHA for 7336312
dev/devicelab/lib/tasks/run_tests.dart
@@ -244,14 +244,14 @@ abstract class RunOutputTask {
244
ready.complete();
245
}
246
});
247
- run.stderr
+ final Stream<String> runStderr = run.stderr
248
.transform<String>(utf8.decoder)
249
.transform<String>(const LineSplitter())
250
+ .asBroadcastStream();
251
+ runStderr.listen((String line) => print('run:stderr: $line'));
252
+ runStderr
253
.skipWhile(isExpectedStderr)
- .listen((String line) {
- print('run:stderr: $line');
- stderr.add(line);
254
- });
+ .listen((String line) => stderr.add(line));
255
unawaited(run.exitCode.then<void>((int exitCode) { runExitCode = exitCode; }));
256
await Future.any<dynamic>(<Future<dynamic>>[ ready.future, run.exitCode ]);
257
if (runExitCode != null) {
0 commit comments