Index: pkg/scheduled_test/lib/scheduled_process.dart |
diff --git a/pkg/scheduled_test/lib/scheduled_process.dart b/pkg/scheduled_test/lib/scheduled_process.dart |
index ad6d4daa4fd8b194928788e1e530fe10d0c8eaee..23370f10942602b5ccc0e42e56dbce3c3d87c70e 100644 |
--- a/pkg/scheduled_test/lib/scheduled_process.dart |
+++ b/pkg/scheduled_test/lib/scheduled_process.dart |
@@ -188,6 +188,12 @@ class ScheduledProcess { |
Future<Stream<List<int>>> streamFuture) { |
return streamWithCanceller(futureStream(streamFuture) |
.handleError((e) => currentSchedule.signalError(e)) |
+ .map((chunk) { |
+ // Whenever the process produces any sort of output, reset the schedule's |
+ // timer. |
+ currentSchedule.heartbeat(); |
+ return chunk; |
+ }) |
.transform(new StringDecoder(_encoding)) |
.transform(new LineTransformer())); |
} |