The supplied function will be called for each item in the queue one at a time.
Add's a queueItem.
Returns a promise that will resolve to the remaining items in the queue.
Close everything.
PRIORITY_QUEUE
, if defined, a priority queue will be used
REDIS_PORT
, the port for Redis
REDIS_HOST
, the host for Redis
- More documentation.
- Tests.
- Remove environment variables, and pass these things in from scraper.js.
2.0.0 - Remove options, extract them from a queueItem instead 3.0.0 - Add options to process() 3.0.2 - Add removeOnComplete to save space in Redis