apache / apache/pulsar-client-reactive
Split InflightLimiter to separate backpressure module
Open
- 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
Assessment
This issue has not been assessed yet.