Merge pull request #35 from srawlins/fix-strong-3
Use LineSplitter.bind to fix String/List<String> type issue
diff --git a/lib/scheduled_process.dart b/lib/scheduled_process.dart
index 5338191..9fdfb29 100644
--- a/lib/scheduled_process.dart
+++ b/lib/scheduled_process.dart
@@ -188,15 +188,15 @@
// Ignore errors from the future. They'll be reported through [schedule].
streamFuture = DelegatingFuture.typed(
streamFuture.catchError((_) => new Stream.fromIterable([])));
- return streamWithCanceller(StreamCompleter.fromFuture(streamFuture)
- .handleError(registerException)
- .map((chunk) {
- // TODO(nweiz): Once this becomes integrated with the test package, add a
- // heartbeat here.
- return chunk;
- })
- .transform(converterTransformer(_encoding.decoder))
- .transform(converterTransformer(new LineSplitter())));
+ return streamWithCanceller(new LineSplitter().bind(
+ StreamCompleter.fromFuture(streamFuture)
+ .handleError(registerException)
+ .map((chunk) {
+ // TODO(nweiz): Once this becomes integrated with the test package,
+ // add a heartbeat here.
+ return chunk;
+ })
+ .transform(converterTransformer(_encoding.decoder))));
}
/// Schedule an exception handler that will clean up the process and provide
