40 packages found
Get a stream as a string, buffer, or array
Return an iterator's length.
Consume an entire iterator and return the last iterated value.
Advances an iterator.
Return the nth iterated value.
Simple function for looping your Node.js stream with C-like for loop features: break and continue
Consume a stream until a given pattern is found
An observable to run async tasks in parallel with a concurrency limit
Easy string consumption
Generates and consumes source maps. Adapted to be commonjs only and work in older browsers.
Dead simple consume & publish for RabbitMQ.
A Fastify plugin for channels implementation based on Redis streams.
- message broker
A simple, lightweight queue using Redis lpush and brpop
An interface for Kafka in Node
Consume streams with a promise-returning function
Redis pre-sharded chanells implementation
consume a json api, minus the boilerplate