backpressure

scalecube/scalecube-services

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

nodefluent/node-sinek

:tophat: Most advanced high level Node.js Kafka client

iheartradio/kanaloa

Make your service more resilient by providing protection against traffic oversaturation

alextanhongpin/go-advance-concurrency

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

pedrokehl/caminho

Tool for creating efficient data pipelines in a JavaScript environment

poelstra/ts-stream

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

apache/pulsar-client-reactive

Reactive client for Apache Pulsar

twisted/tubes

A series of tubes.

exini/dicom-streams-js

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

coreyauger/reactive-gremlin

akka http gremlin 3 websocket connector

RTBHOUSE/kafka-workers

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

piomin/sample-spring-webflux

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

MichaelSchneeberger/rxbp

A back-pressured rxpy extension

baygeldin/ws-streamify

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

tailhook/async-listen

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

daliclass/rxpy-backpressure

Back pressure strategies for use with RxPy

iximiuz/producer-consumer-vis

Producer-consumer problem visualization

ThomWright/congestion-limiter

🪗 Dynamic congestion-based concurrency limits for controlling backpressure

exini/dicom-streams

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

usedatabrew/tango

Open Source pipeline lib with backpressure

vlingo/xoom-streams

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

sinclairzx81/corsa

Asynchronous uni-directional channels in node using async iteration.

r-k-b/backpressure-queue

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

Jackstone92/CombineRx

Helpful bridging functions between RxSwift and Combine frameworks

dshcherbatiuk/java-nio

Examples what we can do with Java NIO Library and how we can manipulate with TCP Flow Control.

mmabdelateef/SimpleTaskQueue

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

DusanKasan/cesium

General purpose 4th generation reactive library for Golang

gregwhitaker/rsocket-backpressure-example

Example of using Backpressure with RSocket

schmitch/akka-pg

DEPRECATED: akka postgresql client (not complete yet)

addityasingh/jobqueue

A lifo job queue to provide back pressure and load shedding

calvinlfer/actors-and-streams

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

j3t/mvnio

Repository for Maven artifacts which uses S3 buckets as storage provider.

makasim/backpressure

ori88c/zero-backpressure-semaphore-typescript

Promise Semaphore for Node.js projects, inspired by the RAII idiom. Offering backpressure control for enhanced efficiency, utilizing a communicative API that signals availability. Additionally, it features a modern API and incorporates mechanisms for graceful termination and error handling.

zhongyuanzhao/dutyBP

Shortest Path Biased Backpressure Routing Using Link Features and Graph Neural Networks