scramjet-core
A pluggable minimal version of Scramjet that focuses only on stream transform and exposes only core features
A pluggable minimal version of Scramjet that focuses only on stream transform and exposes only core features
Lightweight and real-time data functional stream programming framework like event-stream, written in ES6 using async await with multi-threading and typescript support
highland-concurrent-flatmap
Redirect errors in a highland stream.
Utility that lets you turn a process into a highland stream.
`highland-diverge` is a building block to enable splitting a Highland stream into two or more other streams that each apply *separate* back-pressure.
Call a node callback with an optional error after stream completes.
Expressively create Oban HTTP responses
response part objects for Oban
Create stream processors with AWS Lambda functions.
JSON stringify stream for highland.js
Fluent syntax for amqp (Rabbit MQ) with (highland) streaming messages and automatic reconnect.
Library for running remote & local shell commands
(Node.js) Extend the native Array with the methods that work with Highland (a JS stream lib).
Highland consumers to execute before the stream is passed on or after a nil is passed on.
improve readibility of your code! 😄 for es6 and coffeescript this is metaprograming used execution context
Takes care of any paginated AWS SDK call, and return the output as a highland.js stream of objects.
S3 listObjects as a highland stream
Mocha plugin to enable Highland streams support
Store middleware for Redux that let's you dispatch streams of actions.