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. its open and designed to accommodate changes. (no sidecar in a form of broker or any kind)

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

🎩 Most advanced high level Node.js Kafka client

Make your service more resilient by providing protection against traffic oversaturation

A series of tubes.

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

akka http gremlin 3 websocket connector

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

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

Back pressure strategies for use with RxPy

The VLINGO/PLATFORM Reactive Streams support built on VLINGO/ACTORS.

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

Fast and sustainable Elasticsearch ingestion, migration, and cloning

Producer-consumer problem visualization

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

DEPRECATED: akka postgresql client (not complete yet)

Avoid race conditions by execute tasks sequentially even across different threads. guarantee only one task is running at a time

Asynchronous uni-directional channels in node using async iteration.

General purpose 4th generation reactive library for Golang

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

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

A lifo job queue to provide back pressure and load shedding

Example of using Backpressure with RSocket

How to handle back button press from Activity to Fragment

.Net Core Console Application that leverages the Azure Cognitive Services Vision SDK to recognize objects in a jpg image file.

Yet another example showing how to use `Sink.actorRef` but with the added twist of using timers

example project to show use of rxpy-backpressure