Package io.reactivex.rxjava3.parallel
Interface ParallelFlowableConverter<T,R>
- Type Parameters:
T
- the upstream typeR
- the output type
- Functional Interface:
- This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
Convenience interface and callback used by the
ParallelFlowable.to(io.reactivex.rxjava3.parallel.ParallelFlowableConverter<T, R>)
operator to turn a ParallelFlowable into
another value fluently.
History: 2.1.7 - experimental
- Since:
- 2.2
-
Method Summary
Modifier and TypeMethodDescriptionapply
(@NonNull ParallelFlowable<T> upstream) Applies a function to the upstream ParallelFlowable and returns a converted value of typeR
.
-
Method Details
-
apply
Applies a function to the upstream ParallelFlowable and returns a converted value of typeR
.- Parameters:
upstream
- the upstream ParallelFlowable instance- Returns:
- the converted value
-