stream method

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

Streams the output of invoking the Runnable on the given input.

• input - the input to invoke the Runnable on.
• options - the options to use when invoking the Runnable.

Implementation

@override
Stream<RunOutput> stream(
  final RunInput input, {
  final RunnableOptions? options,
}) async* {
  final runnable = await router.call(input, options);
  yield* runnable.stream(input, options: options);
}