We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Signature:
ParallelTransformer<T, R> transformRail(BiFunction<Flowable<T>, Integer, Publisher<R> mapper)
Given the parallelism of the ParallelFlowable, the function will be called for each rail indexed 0..n-1 to provide a mapping for that particular rail.
ParallelFlowable
Considerations:
Flowable
Publisher
See also https://github.com/akarnokd/RxJavaMicroprofileRS/blob/master/src/main/java/hu/akarnokd/rxjava3/mprs/DeferredProcessor.java
The text was updated successfully, but these errors were encountered:
No branches or pull requests
Signature:
Given the parallelism of the
ParallelFlowable
, the function will be called for each rail indexed 0..n-1 to provide a mapping for that particular rail.Considerations:
Flowable
s will be single-subscriber only.Publisher
may not be connected to the inputFlowable
for a time or at all.Flowable
may terminate before the downstream gets to subscribing to it.See also https://github.com/akarnokd/RxJavaMicroprofileRS/blob/master/src/main/java/hu/akarnokd/rxjava3/mprs/DeferredProcessor.java
The text was updated successfully, but these errors were encountered: