@proto-kit/sequencer • Docs

Documentation / @proto-kit/sequencer / FlowTaskWorker

Class: FlowTaskWorker

Implements

• Closeable

Constructors

new FlowTaskWorker()

new FlowTaskWorker(mq, tasks): FlowTaskWorker

Parameters

• mq: TaskQueue

• tasks: Task<any, any>[]

Returns

FlowTaskWorker

Defined in

packages/sequencer/src/worker/worker/FlowTaskWorker.ts:20

Properties

preparePromise?

optional preparePromise: Promise<void>

Defined in

packages/sequencer/src/worker/worker/FlowTaskWorker.ts:68

prepareResolve()?

optional prepareResolve: () => void

Returns

void

Defined in

packages/sequencer/src/worker/worker/FlowTaskWorker.ts:70

Methods

close()

close(): Promise<void>

Returns

Promise<void>

Implementation of

Closeable.close

Defined in

packages/sequencer/src/worker/worker/FlowTaskWorker.ts:170

prepareTasks()

prepareTasks(tasks): Promise<void>

Parameters

• tasks: Task<unknown, unknown>[]

Returns

Promise<void>

Defined in

packages/sequencer/src/worker/worker/FlowTaskWorker.ts:76

start()

start(): Promise<void>

Returns

Promise<void>

Defined in

packages/sequencer/src/worker/worker/FlowTaskWorker.ts:104

waitForPrepared()

waitForPrepared(): Promise<void>

Returns

Promise<void>

Defined in

packages/sequencer/src/worker/worker/FlowTaskWorker.ts:72