Class OperatorWindowWithStartEndObservable<T,U,V>

java.lang.Object
rx.internal.operators.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.
  • Field Details

    • windowOpenings

      final Observable<? extends U> windowOpenings
    • windowClosingSelector

      final Func1<? super U,? extends Observable<? extends V>> windowClosingSelector
  • Constructor Details

    • OperatorWindowWithStartEndObservable

      public OperatorWindowWithStartEndObservable(Observable<? extends U> windowOpenings, Func1<? super U,? extends Observable<? extends V>> windowClosingSelector)
  • Method Details