3.x: Add blockingForEach(Consumer, int) overload by akarnokd · Pull Request #6800 · ReactiveX/RxJava (original) (raw)

The underlying blockingIterable already supported the custom prefetch overload and this PR exposes it as a new blockingForEach overload.

In addition, the Javadocs incorrectly stated blockingForEach operated in an unbounded-in fashion. It uses the usual stable-prefetch with 75% re-request amount.

Resolves #6784