Class OperatorWindowWithObservableFactory<T,U>

java.lang.Object
rx.internal.operators.OperatorWindowWithObservableFactory<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 OperatorWindowWithObservableFactory<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

    • otherFactory

      final Func0<? extends Observable<? extends U>> otherFactory
    • 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

    • OperatorWindowWithObservableFactory

      public OperatorWindowWithObservableFactory(Func0<? extends Observable<? extends U>> otherFactory)
  • Method Details