backpressure
There are 56 repositories under backpressure topic.
hivemq/hivemq-mqtt-client
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
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.
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.
pedrokehl/caminho
Tool for creating efficient data pipelines in a JavaScript environment
RTBHOUSE/kafka-workers
Kafka Workers is a client library which unifies records consuming from Kafka and processing them by user-defined WorkerTasks.
coreyauger/reactive-gremlin
akka http gremlin 3 websocket connector
exini/dicom-streams-js
A streaming and non-blocking API for reading and processing DICOM data
piomin/sample-spring-webflux
testing webclient reactive communication with spring boot reactive application built on top of spring webflux
MichaelSchneeberger/rxbackpressure
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
usedatabrew/tango
Open Source pipeline lib with backpressure
vlingo/xoom-streams
The VLINGO XOOM platform SDK for Reactive Streams built on XOOM ACTORS.
exini/dicom-streams
A streaming and non-blocking API for reading and processing DICOM data
sinclairzx81/corsa
Asynchronous uni-directional channels in node using async iteration.
ThomWright/squeeze
Dynamic congestion-based concurrency limits for controlling backpressure
Jackstone92/CombineRx
Helpful bridging functions between RxSwift and Combine frameworks
r-k-b/backpressure-queue
Pipe nodejs streams into an async.queue for parallelisation, get backpressure when the queue is full.
dshcherbatiuk/java-nio
Examples what we can do with Java NIO Library and how we can manipulate with TCP Flow Control.
gregwhitaker/rsocket-backpressure-example
Example of using Backpressure with RSocket
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
schmitch/akka-pg
DEPRECATED: akka postgresql client (not complete yet)
addityasingh/jobqueue
A lifo job queue to provide back pressure and load shedding
antonbashir/dart-reactive-transport
Dart Linux IOUring based RSocket transport
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.
geraldo916/Stream-Project-01
A simple app that read 1000 line of data from database and Stream it to client using Web Streams
Showndarya/Apache-Flink-Cloud-Bursting
Addressing transient workload spikes with Cloud bursting in Apache Flink