Search results
96 packages found
Given a MongoDB query cursor, process the results in parallel, up to the specified limit.
It contains 3 common methods for processing batch tasks, PromiseAnyway, which runs with limit concurrency and resolve after all jobs done; Queue class, async job queue with concurrency control; batchSlice, Synchronized batch task processing
Promise.all() with concurrency limit
Set of methods allowing simplify work with promises in cycle such as: forEach, map, find, filter, reduce, while, transform. Besides there are methods for comfortable work with promises or asynchronous operations - all, retry, timeout.
- promise
- promises
- performance
- async
- await
- deferred
- deferreds
- future
- flow control
- fluent interface
- promise methods
- foreach
- reduce
- filter
- View more
Concurrency control for awaiting an array of async results
A promise based throttler capable of limiting execution of parallel tasks
Run an array of functions in parallel, but limit the number of tasks executing at the same time
- parallel
- async
- function
- callback
- asynchronous
- run
- array
- run parallel
- limit
- max
- queue
- run parallel limit
- max tasks
- tasks
An observable to run async tasks in parallel with a concurrency limit
Await an array of async functions with parallel limit.
Run an async task for each array element in parallel, but limit the number of tasks executing at the same time.
yet another async control flow engine
Run all promises in serie/parallelLimit/parallel and returns results for all.
Queue promises into pool limiting concurrency
Run promise-returning & async functions concurrently with optional limited concurrency
Parallel run co tasks with concurrent limit
A queue which will callback to a user defined function on each item of the queue, limiting parallel tasks using promises and deferreds.
A small utility for running functions in parallel with limiting running jobs.
Maximize the parallel calls of an iterator supporting asyncIterator interface
Limits the maximum number of asynchronous processes that can be executed
A useful, zero dependencies toolbox to handle different situations like trigerring sequential Promises, a sequence with pause in between, parallel execution and limited parallel execution