rx.internal.operators

Class OperatorOnErrorFlatMap<T>

  • All Implemented Interfaces:
    Func1<Subscriber<? super T>,Subscriber<? super T>>, Function, Observable.Operator<T,T> 

    public final class OperatorOnErrorFlatMap<T>
extends Object
implements Observable.Operator<T,T>
    Allows inserting onNext events into a stream when onError events are received and continuing the original sequence instead of terminating. Thus it allows a sequence with multiple onError events.