davidmoten / davidmoten/rxjava-extras
Transformer.orderedMergeWith: Allow configuring Source Observable Backpressure BufferSize
- Dominant language
- Java
- Stars
- 271
- Forks
- 28
- Avg merge
- 2m
- Merged PRs (30d)
- 1
Description
Hi David,
We are using rxjava-extras as a dependency:
https://mvnrepository.com/artifact/com.microsoft.azure/azure-cosmosdb/1.0.0
https://github.com/Azure/azure-cosmosdb-java
We are using `Transformer.orderedMergeWith`.
It appears to me that in the implementation of BackPressure for the above operator for each of the source observables, `RxRingBuffer.SIZE` items will be buffered. Am I right?
https://github.com/davidmoten/rxjava-extras/blob/08e66ff7ab2ef530292ff1ee1e1f4827aafee08e/src/main/java/com/github/davidmoten/rx/internal/operators/OrderedMerge.java#L307
If not already supported, is that possible to provide a overload for `Transformer.orderedMergeWith` which allows configuring the buffered size for each source observable? It is critical for our use case.
Thank you @davidmoten
Contributor guide
No contributing guide indexed for this repository
Assessment
This issue has not been assessed yet.