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

🎩 (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.

Chain functions, generators, Node streams, and Web streams into a pipeline with backpressure support.

Tool for creating efficient data pipelines in a JavaScript environment

Reactive client for Apache Pulsar

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

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

A series of tubes.

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

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

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

A back-pressured rxpy extension

akka http gremlin 3 websocket connector

Physics-based Traffic Control

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

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

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