invoke method

@override Future<RunOutput> invoke(RunInput input, { RunnableOptions? options, })

Invokes the RunnableMapInputStream on the given input.

• input - the input to invoke the RunnableMapInputStream on.
• options - not used.

Implementation

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