158 packages found
Promise queue with concurrency control
- promise
- queue
- enqueue
- limit
- limited
- concurrency
- throttle
- throat
- rate
- batch
- ratelimit
- priority
- priorityqueue
- fifo
- View more
Tiny queue data structure
Easy to Use ReactiveX Queue that Supports Delay/DelayExecutor/Throttle/Debounce/Concurrency Features Powered by RxJS/IxJS
Fifo queue with concurrency control
A task queue executes tasks sequentially or concurrently. Wrap an async/promise-returning/sync function as a queue-ready async function for easy reusing. Support passing arguments/getting return value, @synchronized/@concurrent decorator, Node.js/Browser.
- task queue
- async
- promise
- await
- sequential
- synchronized
- decorator
- lock
- concurrency
- throttle
- typescript
- javascript
- node
- browser
- View more
A FIFO (first-in-first-out) queue using promises
Train a fast (FIFO) queue with a rollback mechanism. Behind the scenes it uses 2 arrays to simulate and perform fast shifting and popping operations without using the Array#shift() method..
A fixed-length, first-in-first-out array.
A buffer that removes its entries after a certain time.
First in, first out data structures for JavaScript
Deques are a generalization of stacks and queues
Priority queuing for leveldb/levelup
Lightweight, optimized, and efficient implementations for FIFO (queue) data structure
Promise queue with concurrency control
- promise
- queue
- enqueue
- limit
- limited
- concurrency
- throttle
- throat
- rate
- batch
- ratelimit
- priority
- priorityqueue
- fifo
- View more
wraps `async.filter` to find items of a particular type in a directory
- async
- blockDevice
- characterDevice
- dir
- directory
- directories
- fifo
- file
- filter
- fs
- isDirectory
- isFile
- socket
- symlink
Simple FIFO queue implementation to avoid having to do shift() on an array, which is slow.
Simple FIFO queue implementation.
Promised First-In-First-Out buffer. Await on push to be told when a value is consumed and await on shift for a value to consume when the buffer is empty.