Explore

Promisify a callback-style function

Delay a promise a specified amount of time

Memoize promise-returning functions, with expire and prefetch

Limit the execution rate of a promise-returning function

Map over promises concurrently

Reactive programming

Convert an Observable to a Promise

Manages synchronous and asynchronous code easily, using nothing more than standard JavaScript and Node-like Streams

Get a stream as a string or buffer

Convert a buffer/string/array/object into a stream

Turn a writeable and readable stream into a single streams2 duplex stream

Combine an array of streams into a single duplex stream

Transform stream that lets you peek the first line before deciding how to parse it

Newline (or any delimiter) splitter stream

Super-simple line-by-line Stream reader

Transform the first chunk in a stream

Pad each line in a stream

Combine multiple streams into a single stream

Mirror of Streams2 and Streams3 implementations in core

Transform object streams concurrently

Highly scalable WebSocket server & client library

Enables real-time bidirectional event-based communication

Real-time client-server message bus, based on Bayeux protocol

Scalable HTTP + WebSocket engine which can run on multiple CPU cores