HiveMQ MQTT Client is an MQTT 5.0 and MQTT 3.1.1 compatible and feature-rich high-performance Java client library with different API flavours and backpressure support

Microservices library - scalecube-services is a high throughput, low latency reactive microservices library built to scale. It features: API-Gateways, service-discovery, service-load-balancing, the architecture supports plug-and-play service communication modules and features. built to provide performance and low-latency real-time stream-processing

:tophat: (legacy) high level Node.js Kafka client

Make your service more resilient by providing protection against traffic oversaturation

A collection of best practices and lessons learnt from applying concurrency in go.

Type-safe object streams with seamless support for backpressure, ending, and error handling

Tool for creating efficient data pipelines in a JavaScript environment

Reactive client for Apache Pulsar

A series of tubes.

Multi-core, Tokio-native orchestration for LLM pipelines.

A streaming and non-blocking API for reading and processing DICOM data

High-performance async runtime for Nim with structured concurrency, lock-free channels, and work-stealing scheduler

akka http gremlin 3 websocket connector

Kafka Workers is a client library which unifies records consuming from Kafka and processing them by user-defined WorkerTasks.

A back-pressured rxpy extension

testing webclient reactive communication with spring boot reactive application built on top of spring webflux

Physics-based Traffic Control

Pipe Node.js streams over WebSockets (with back-pressure!).

Lightweight in-memory queue + scheduler for Go with middleware-style hooks and capacity/backpressure control.

A rust crate with various helpers for writing production-ready servers in rust using async-std

Embedded scheduling core for stable output under backpressure (ESP32 demo)

🪗 Dynamic concurrency limits for controlling backpressure, inspired by TCP congestion control

Back pressure strategies for use with RxPy

Producer-consumer problem visualization

Open Source pipeline lib with backpressure

The VLINGO XOOM platform SDK for Reactive Streams built on XOOM ACTORS.

Asynchronous uni-directional channels in node using async iteration.

Synthesizable AXI4 crossbar with a full UVM verification environment — RTL, SVA, coverage, stress, and CI.

Pipe nodejs streams into an async.queue for parallelisation, get backpressure when the queue is full.

Helpful bridging functions between RxSwift and Combine frameworks