Variable createWorkflowSharedHandlerConst

Type Declaration

• • <O, I = void, TState extends TypedState = UntypedState>(
        opts: WorkflowHandlerOpts<I, O>,
        fn: (ctx: WorkflowSharedContext<TState>, input: I) => Promise<O>,
    ): I extends void
        ? (ctx: WorkflowSharedContext) => Promise
        : (ctx: WorkflowSharedContext<TState>, input: I) => Promise<O>

  • Creates a shared handler for a workflow.

    A shared handler allows a read-only concurrent execution for a given key.

    Type Parameters

    • O
    • I = void
    • TState extends TypedState = UntypedState

    Parameters

    • opts: WorkflowHandlerOpts<I, O>

      additional configurations

    • fn: (ctx: WorkflowSharedContext<TState>, input: I) => Promise<O>

      the handler to execute

    Returns I extends void
        ? (ctx: WorkflowSharedContext) => Promise
        : (ctx: WorkflowSharedContext<TState>, input: I) => Promise<O>

  • <O, I = void, TState extends TypedState = UntypedState>(
        fn: (ctx: WorkflowSharedContext<TState>, input: I) => Promise<O>,
    ): I extends void
        ? (ctx: WorkflowSharedContext) => Promise
        : (ctx: WorkflowSharedContext<TState>, input: I) => Promise<O>

  • Creates a shared handler for a workflow.

    A shared handler allows a read-only concurrent execution for a given key.

    Type Parameters

    • O
    • I = void
    • TState extends TypedState = UntypedState

    Parameters

    • fn: (ctx: WorkflowSharedContext<TState>, input: I) => Promise<O>

      the handler to execute

    Returns I extends void
        ? (ctx: WorkflowSharedContext) => Promise
        : (ctx: WorkflowSharedContext<TState>, input: I) => Promise<O>