Class ParallelDoOnNextTry<T>

java.lang.Object
io.reactivex.rxjava3.parallel.ParallelFlowable<T>
io.reactivex.rxjava3.internal.operators.parallel.ParallelDoOnNextTry<T>
Type Parameters:
T - the input value type

public final class ParallelDoOnNextTry<T> extends ParallelFlowable<T>
Calls a Consumer for each upstream value passing by and handles any failure with a handler function.

History: 2.0.8 - experimental

Since:
2.2