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

🎩 Most advanced 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.

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.

akka http gremlin 3 websocket connector

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

A back-pressured rxpy extension

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

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

Back pressure strategies for use with RxPy

Producer-consumer problem visualization

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

Open Source pipeline lib with backpressure