Skip to content

ThroughputDispatcher

Defined in: src/Dispatcher.ts:57

Processes up to throughput queued units synchronously before yielding. Useful when actors exchange many small messages and you want less scheduling overhead. Be aware that you can starve the event loop if throughput is set high.

new ThroughputDispatcher(throughput?, id?): ThroughputDispatcher

Defined in: src/Dispatcher.ts:62

number = 16

string = 'throughput-dispatcher'

ThroughputDispatcher

readonly id: string

Defined in: src/Dispatcher.ts:58

Dispatcher.id


readonly throughput: number = 16

Defined in: src/Dispatcher.ts:62

execute(fn): void

Defined in: src/Dispatcher.ts:66

Schedule a unit of work to be executed asynchronously.

() => void | Promise<void>

void

Dispatcher.execute