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.
- fastify
- plugin
- redis
- cluster
- pre-sharded
- channel
- stream
- message broker
- produce
- consume
- pub/sub
- websocket
- SSE
- eventsource
Advances an iterator.
Return an iterator's length.
Return the nth iterated value.
Dead simple consume & publish for RabbitMQ.
Iterable consumption for JavaScript
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
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 a json api, minus the boilerplate
WrixJS is builded whit WrixJS: a Javascript lib to compose chainable libs and frameworks.