Backpressure
Showing 22 of 22 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 Node.js module that pipes streams together and automatically destroys all streams if one closes or errors.
A Haskell library for streaming data processing with constant memory usage, deterministic resource handling, and easy composition.
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.
A fixed-length blocking queue implemented as a GenServer in Elixir for producer-consumer coordination.
A high-throughput Akka HTTP Gremlin 3 WebSocket connector with built-in backpressure to prevent server overload.
A configurable GenStage-based bulk processor for efficiently inserting data into Elasticsearch from Elixir applications.
A zero-config, auto-scaling worker pool for Go with priority-aware scheduling, adaptive resource management, and per-task retry logic.
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.