invoke method

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

Invokes the RunnableFunction on the given input.

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

Implementation

@override
Future<RunOutput> invoke(
  final RunInput input, {
  final RunnableOptions? options,
}) async {
  if (_invokeFunc != null) {
    return _invokeFunc(input, options);
  } else {
    return stream(input, options: options).first;
  }
}