apache / apache/pulsar-client-reactive

Split InflightLimiter to separate backpressure module

Open
#2 0 comments 0 reactions 0 assignees View on GitHub
Dominant language
Java
Stars
67
Forks
23
Avg merge
22h
Merged PRs (30d)
2

Description

InflightLimiter is a generic Reactive operator for limiting the number of concurrent elements in progress. It is used in the current adapter based implementation to achieve asynchronous non-blocking backpressure. The InflightLimiter implementation depends on JCTools library which provides a high performance queue implementation that is used in the solution.
It would be useful to move InflightLimiter to an independent module so that it could be used on its own. Contributing InflightLimiter to resilience4j-reactor would be useful too.

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.