29 repository-uri
Libraries for managing asynchronous operations and streams.
Explore 29 awesome GitHub repositories matching part of an awesome list · Control Flow Utilities. Refine with filters or upvote what's useful.
RxJS is a library for reactive programming that provides a framework for composing asynchronous and event-based programs. It utilizes observable sequences to model data flows, allowing developers to manage complex sequences of events through a declarative programming interface. The library implements the observer pattern to facilitate decoupled communication between data producers and subscribers. By employing a lazy execution model, streams remain dormant until a consumer explicitly subscribes, at which point data production is triggered. This approach enables the construction of predictable
Library for reactive programming using observables.
Async is a JavaScript asynchronous flow library designed to manage the execution and coordination of asynchronous tasks in Node.js and the browser. It provides functional utilities to wrap, process, and orchestrate complex asynchronous workflows. The library distinguishes itself through a comprehensive task orchestrator that handles dependency graphs to resolve circular references and manages concurrent task queues. It includes a unification bridge that allows callback-style and promise-based functions to operate within the same execution interface. The project covers several primary capabil
Asynchronous utilities for Node and browser.
Bluebird is a JavaScript promise library designed for managing asynchronous operations with a custom promise implementation. It provides a framework for controlling promise lifecycles and orchestrating non-blocking programming patterns. The library distinguishes itself with an asynchronous debugging toolkit that captures long stack traces across asynchronous boundaries and a global handler for unhandled promise rejections. It includes a predicate-based error filtering system to target specific exception types and a mechanism for the deterministic cleanup of system resources. It covers a broa
High-performance, feature-rich promise library.
q is a JavaScript promise library and asynchronous flow controller designed to manage non-blocking operations. It serves as a system for coordinating parallel tasks and sequencing asynchronous workflows through task chaining and error propagation. The library distinguishes itself with specialized debugging tools that capture long stack traces across asynchronous jumps and monitor unhandled rejections to prevent silent failures. It also functions as a remote object proxy, forwarding method calls to remote targets and routing responses back through promises. The project provides comprehensive
Tool for composing asynchronous promises.
High-level streams library for Node.js and the browser
Utility for managing synchronous and asynchronous streams.
A solid, fast Promises/A+ and when() implementation, plus other async goodies.
Fast Promises/A+ implementation.
An async control-flow library that makes stepping through logic easy.
Simplifying asynchronous logic flow.
Promisify a callback-style function
Promisify callback-style functions.
Map over promises concurrently
Concurrent mapping over promises.
Node-core streams for userland
Mirror of core stream implementations.
:surfer: Asynchronous flow control with a functional taste to it
Functional-style asynchronous flow control.
Delay a promise a specified amount of time
Utility to delay promise execution.
Get a stream as a string, Buffer, ArrayBuffer or array
Read streams as strings or buffers.
Line-by-line Stream reader for node.js
Simple line-by-line stream reader.
A stream that emits multiple other streams one after another (streams3)
Combine multiple streams into one.
Combine an array of streams into a single duplex stream using pump and duplexify
Combine multiple streams into a single duplex stream.
Convert a string/promise/array/iterable/asynciterable/buffer/typedarray/arraybuffer/object into a stream
Convert buffers, strings, or objects into streams.
Turn a writable and readable stream into a streams2 duplex stream with support for async initialization and streams1/streams2 input
Combine readable and writable streams into a duplex stream.
Convenience wrapper for ReadableStream, with an API lifted from "from" and "through2"
Convenience wrapper for creating readable streams.
a fast newline (or any delimiter) splitter stream - like require('split') but specific for binary data
Stream splitter for delimiters like newlines.