Class BloscDecodeDispatcher

Where WorkerBloscCodec sends decodes (the data-worker pool).

Implements

BloscDecodeBackend

Index

Constructors

Properties

queue flushScheduled pool

Methods

decode flush dispatch

Constructors

constructor

new BloscDecodeDispatcher(pool: CodecPoolPort): BloscDecodeDispatcher
Parameters
- pool: CodecPoolPort
Returns BloscDecodeDispatcher
- Defined in src/workers/worker-pool/codec-dispatch.ts:95

Properties

`Private`queue

queue: Pending[] = []

`Private`flushScheduled

flushScheduled: boolean = false

`Private` `Readonly`pool

pool: CodecPoolPort

Methods

decode

decode(request: BloscDecodeRequest): Promise<Uint8Array<ArrayBufferLike>> | null
Decode off the main thread, or return null when no worker can take the job right now (the codec then decodes locally). A rejection also falls back to the local decode.
Parameters
- request: BloscDecodeRequest
Returns Promise<Uint8Array<ArrayBufferLike>> | null
Implementation of BloscDecodeBackend.decode
- Defined in src/workers/worker-pool/codec-dispatch.ts:97

`Private`flush

flush(): void
Returns void
- Defined in src/workers/worker-pool/codec-dispatch.ts:110

`Private`dispatch

dispatch(batch: Pending[]): void
Parameters
- batch: Pending[]
Returns void
- Defined in src/workers/worker-pool/codec-dispatch.ts:121