streamFromInputStream method
Stream<RunOutput>
streamFromInputStream(
- Stream<
RunInput> inputStream, { - RunnableOptions? options,
override
Streams the inputStream
through the RunnableMapInputStream.
inputStream
- the input stream to stream through the RunnableMapInputStream.options
- not used.
Implementation
@override
Stream<RunOutput> streamFromInputStream(
final Stream<RunInput> inputStream, {
final RunnableOptions? options,
}) {
return inputStreamMapper(inputStream);
}