streamFromInputStream method
Stream<RunOutput>
streamFromInputStream(
- Stream<
RunInput> inputStream, { - RunnableOptions? options,
override
Streams the output of invoking the Runnable on the given inputStream
.
Implementation
@override
Stream<RunOutput> streamFromInputStream(
final Stream<RunInput> inputStream, {
final RunnableOptions? options,
}) async* {
final input = await inputStream.toList();
final reduced = reduce<RunInput>(input);
yield* stream(reduced, options: options);
}