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);
}