stream method

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

Streams the input through the RunnableFunction.

  • input - the input to stream through the RunnableFunction.
  • options - the options to use when streaming the input.

Implementation

@override
Stream<RunOutput> stream(
  final RunInput input, {
  final RunnableOptions? options,
}) {
  return streamFromInputStream(Stream.value(input), options: options);
}