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