@pooley/queues NPM

@pooley/queues

Implements different queues for @pooley/core.

Queue	Description
BufferedQueue	Allows to buffer requests to dequeue elements from a queue and flush them once data has arrived.

Install

Install the library with it's core peer dependency:

npm install @pooley/queues @pooley/core

Usage

BufferedQueue

import { WorkerPool } from '@pooley/core';
import { BufferedQueue } from '@pooley/queues';

// Create a buffered queue
const queue = new BufferedQueue<string>();

// Create a pool with it
const pool = new WorkerPool({
  task,
  queue,
  poolScaler,
  processorFactory,
});

// Start pushing into the queue
queue.pushAll(['some', 'data']);

Configuration

Option	Default	Description
bufferSize	Infinity	Maximum size of dequeue requests that queue should buffer before triggering a buffer overflow strategy
bufferOverflowStrategy	Throws an error	A strategy function that is triggered when the dequeue buffer is overflown