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.
- fastify
- plugin
- redis
- cluster
- pre-sharded
- channel
- stream
- message broker
- produce
- consume
- pub/sub
- websocket
- SSE
- eventsource
A simple, lightweight queue using Redis lpush and brpop
Utilities for JavaScript Iterable and AsyncIterable
An interface for Kafka in Node
- kafka
- broker
- librdkafka
- node-rdkafka
- pubsub
- pub-sub
- message
- messages
- queue
- queues
- topics
- produce
- consume
- producer
Consume streams with a promise-returning function
WrixJS is builded whit WrixJS: a Javascript lib to compose chainable libs and frameworks.
Redis pre-sharded chanells implementation
consume a json api, minus the boilerplate