Skip to content

Conversation

akarnokd
Copy link
Member

@akarnokd akarnokd commented Dec 1, 2014

Fixes include:

  • do not decrement the client capacity if it is unbounded,
  • do not request 0,
  • propagate request count (n) instead of capacity + request (c + n),
  • FuncWithErrors to support backpressure; there was a non-zero chance the final succeding pair of onNexts would trigger a MissingBackpressureException.

benjchristensen added a commit that referenced this pull request Dec 1, 2014
Fixed retry without backpressure & test function to support bp.
@benjchristensen benjchristensen merged commit f46d7f9 into ReactiveX:1.x Dec 1, 2014
@akarnokd akarnokd deleted the RetryWithBackpressureFix branch December 9, 2014 13:28
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants