Package rx.internal.operators
Class OperatorWindowWithObservableFactory<T,U>
java.lang.Object
rx.internal.operators.OperatorWindowWithObservableFactory<T,U>
- Type Parameters:
T
- the value typeU
- 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.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static final class
Observes the boundary.(package private) static final class
Observes the source. -
Field Summary
FieldsModifier and TypeFieldDescription(package private) static final Object
Indicate the current subject should complete and a new subject be emitted.(package private) static final NotificationLite
<Object> For error and completion indication.(package private) final Func0
<? extends Observable<? extends U>> -
Constructor Summary
ConstructorsConstructorDescriptionOperatorWindowWithObservableFactory
(Func0<? extends Observable<? extends U>> otherFactory) -
Method Summary
Modifier and TypeMethodDescriptionSubscriber
<? super T> call
(Subscriber<? super Observable<T>> child)