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
Type-safe object streams with seamless support for backpressure, ending, and error handling
Reactive client for Apache Pulsar
Multi-core, Tokio-native orchestration for LLM pipelines.
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.
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.
Add a description, image, and links to the backpressure topic page so that developers can more easily learn about it.
To associate your repository with the backpressure topic, visit your repo's landing page and select "manage topics."