Backpressure
Showing 18 of 18 projects
A Java VM library for composing asynchronous and event-based programs using observable sequences.
A JVM library for composing asynchronous and event-based programs using observable sequences.
A standard specification for asynchronous stream processing with non-blocking backpressure on the JVM.
A tiny wrapper around Node.js streams.Transform to simplify stream creation without subclassing.
A Reactive Streams connector for Apache Kafka built on Akka Streams, enabling back-pressured integration for Java and Scala.
A high-performance, feature-rich Java client library for MQTT 5.0 and 3.1.1 with multiple API flavors and backpressure support.
A Clojure library providing deferreds and streams for asynchronous programming and interoperability between event-driven abstractions.
A Haskell library for streaming data processing with constant memory usage, deterministic resource handling, and easy composition.
A Node.js module that pipes streams together and automatically destroys all streams if one closes or errors.
A high-throughput, low-latency reactive microservices library with built-in service discovery, load balancing, and pluggable API gateways.
A high-throughput, low-latency reactive microservices library with built-in service discovery, load balancing, and pluggable API gateways.
A .NET library for high-performance push-based stream processing, now part of System.IO.Pipelines.
A collection of utilities, operators, and serialization helpers for RxJava 1 to simplify reactive programming tasks.
Convert strings, promises, arrays, buffers, objects, and other data types into Node.js streams with proper backpressure handling.
A .NET standard for asynchronous stream processing with non-blocking backpressure, enabling interoperability between reactive libraries.
A high-level Node.js module for creating readable streams with proper backpressure handling and a familiar API.
A synchronous transform stream for Node.js with 10x performance over standard Transform streams.
RxJava observables for file operations including NIO watch events and tailing.
Related Tags
Found a gem we're missing?
Open-Awesome is built by the community, for the community. Submit a project, suggest an awesome list, or help improve the catalog on GitHub.