davidmoten / davidmoten/rxjava-extras

Transformer.orderedMergeWith: Allow configuring Source Observable Backpressure BufferSize

Open
#29 5 comments 0 reactions 0 assignees View on GitHub
enhancement
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.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.