rx.internal.operators

Class OperatorWindowWithStartEndObservable<T,U,V>

  • Type Parameters:
    T - the value type
    U - the type of the window opening event
    V - the type of the window closing event
    All Implemented Interfaces:
    Func1<Subscriber<? super Observable<T>>,Subscriber<? super T>>, Function, Observable.Operator<Observable<T>,T> 

    public final class OperatorWindowWithStartEndObservable<T,U,V>
extends Object
implements Observable.Operator<Observable<T>,T>
    Creates potentially overlapping windows of the source items where each window is started by a value emitted by an observable and closed when an associated Observable emits a value or completes.