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 java.lang.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 Detail

      • windowOpenings

        final Observable<? extends U> windowOpenings
      • windowClosingSelector

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

      • OperatorWindowWithStartEndObservable

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