@bitsinfra/fusee
    Preparing search index...

    Interface Concurrency<I>

    Runs at once: at most limit runs of the type run at a time, or of each key (key(input), a tenant say); the others wait, in the order they were started, as fusee.queued/<id> runs, and result() waits through the queue. The turns are durable: a run keeps its turn while it sleeps and across crashes. Starts from outside a workflow (an engine, a client, the HTTP API) take turns; a child started by a workflow does not.

    interface Concurrency<I = unknown> {
        key?: (input: I) => string;
        limit: number;
    }

    Type Parameters

    • I = unknown
    Index
    key?: (input: I) => string
    limit: number