Registry / devops / pipeline-queue

pipeline-queue

JSON →
library2.0.0jsnpmunverified

A simple request or action queue that pipelines requests for long-running resources, batching callbacks to reduce load. Version 2.0.0 uses CommonJS. Unlike general-purpose queues (e.g., Bull or Bee-Queue), pipeline-queue focuses on deduplicating concurrent requests for the same resource key, ensuring the resource only handles one request at a time. Suitable for rate-limiting or caching expensive operations.

devops
npm install pipeline-queue
github ↗package ↗homepage ↗
INSTALL
IMPORT
SIG · PIPELINE-QUEUE
P
pipeline-queue
devopsjavascriptv2.0.0
harness data pending
Install & Compatibility
Where this runs

No compatibility data collected yet for this library.

Code
Verified usage

Verified import paths — ran on the pinned version, not inferred.

default (PipelineQueue)
✓ const PipelineQueue = require('pipeline-queue');
✗ import PipelineQueue from 'pipeline-queue';
Package is CJS-only; no ES module support.

Shows how to create a queue and run a task with two callbacks for the same key, demonstrating deduplication.

const PipelineQueue = require('pipeline-queue'); const queue = PipelineQueue(); const key = 'unique-resource'; const task = (callback) => { // Simulate long-running operation setTimeout(() => { callback(null, { data: 'result' }); }, 1000); }; const callback1 = (err, results) => { if (err) console.error(err); else console.log('Callback 1:', results); }; const callback2 = (err, results) => { if (err) console.error(err); else console.log('Callback 2:', results); }; queue.run(key, task, callback1); queue.run(key, task, callback2); // callback2 will be queued and receive same results
Debug
Known issues
gotchaTask function must call its callback (usually the first argument) to release queued callbacks. If the task never calls its callback, queued callbacks will never fire.
fix
Ensure your task function accepts and invokes a callback.
affects: >=1.0.0
gotchaThe queue does not automatically clean up after completion; repeated calls to queue.run with the same key will re-execute the task. No caching beyond the current pending request.
fix
Manage cache separately if needed.
affects: >=1.0.0
Errors
Common errors & fixes
TypeError: PipelineQueue is not a function
Using ES module import syntax instead of CommonJS require.
fix
Use const PipelineQueue = require('pipeline-queue');
Error: Callback must be a function
Passed a non-function as callback (e.g., null or undefined).
fix
Ensure the third argument to queue.run() is a function.
Upgrade
Version history
2.0.0latest on npm
Audit
Dependencies

No dependency data recorded yet.

Agent activity
7 hits · last 30 days
node
6
Resources
githubgit://github.com/scull7/request-queue ↗
packagepipeline-queue ↗
homepagehttps://github.com/scull7/request-queue#readme ↗
pipeline-queue — npm install pipeline-queue · libregistry