Class OperatorWindowWithObservable<T,U>

java.lang.Object
rx.internal.operators.OperatorWindowWithObservable<T,U>
Type Parameters:
T - the value type
U - the boundary value type
All Implemented Interfaces:
Func1<Subscriber<? super Observable<T>>,Subscriber<? super T>>, Function, Observable.Operator<Observable<T>,T>

public final class OperatorWindowWithObservable<T,U> extends Object implements Observable.Operator<Observable<T>,T>
Creates non-overlapping windows of items where each window is terminated by an event from a secondary observable and a new window is started immediately.
  • Field Details

    • other

      final Observable<U> other
    • NEXT_SUBJECT

      static final Object NEXT_SUBJECT
      Indicate the current subject should complete and a new subject be emitted.
    • NL

      static final NotificationLite<Object> NL
      For error and completion indication.
  • Constructor Details

    • OperatorWindowWithObservable

      public OperatorWindowWithObservable(Observable<U> other)
  • Method Details