Type Alias FlowFn<I, O, S>

FlowFn: (
input: TypeOf<I>,
streamingCallback: FlowSideChannel<TypeOf<S>>,
) => Promise<TypeOf<O>> | TypeOf<O>

Function to be executed in the flow.

Type Parameters

I extends ZodTypeAny = ZodTypeAny
O extends ZodTypeAny = ZodTypeAny
S extends ZodTypeAny = ZodTypeAny

Type declaration

- (
  input: TypeOf<I>,
  streamingCallback: FlowSideChannel<TypeOf<S>>,
  ): Promise<TypeOf<O>> | TypeOf<O>
- Parameters
  - input: TypeOf<I>
  - streamingCallback: FlowSideChannel<TypeOf<S>>
  Returns Promise<TypeOf<O>> | TypeOf<O>