Claus Ibsen created CAMEL-11125:
-----------------------------------
Summary: camel-reactive-streams - Consumer should allow to not
refill so frequently
Key: CAMEL-11125
URL: https://issues.apache.org/jira/browse/CAMEL-11125
Project: Camel
Issue Type: Improvement
Components: camel-reactive-streams
Reporter: Claus Ibsen
Every time a consumer has completed onNext it calculates a refill, and because
it has completed 1 message, it will always ask for at least 1 message.
This happens even if there is 127 messages already in the buffer.
We should probably have some way of having a low/high watermark so if the
buffer has many messages already we dont need to refill so frequently.
This happens in the code:
org.apache.camel.component.reactive.streams.engine.CamelSubscriber#onNext
By having those watermark threshold we allow to not be so chatty and request
data all the time, but instead request data in more bulks. Otherwise chances
are that we just keep requesting = 1 all the time.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
