streamFromInputStream method

  1. @override
Stream<RunOutput> streamFromInputStream(
  1. Stream<RunInput> inputStream, {
  2. RunnableOptions? options,
})
override

Streams the inputStream through the RunnableMapInputStream.

Implementation

@override
Stream<RunOutput> streamFromInputStream(
  final Stream<RunInput> inputStream, {
  final RunnableOptions? options,
}) {
  return inputStreamMapper(inputStream);
}