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 java.lang.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 Classes Modifier and Type Class Description (package private) static class
OperatorWindowWithObservableFactory.BoundarySubscriber<T,U>
Observes the boundary.(package private) static class
OperatorWindowWithObservableFactory.SourceSubscriber<T,U>
Observes the source.
-
Field Summary
Fields Modifier and Type Field Description (package private) static java.lang.Object
NEXT_SUBJECT
Indicate the current subject should complete and a new subject be emitted.(package private) static NotificationLite<java.lang.Object>
NL
For error and completion indication.(package private) Func0<? extends Observable<? extends U>>
otherFactory
-
Constructor Summary
Constructors Constructor Description OperatorWindowWithObservableFactory(Func0<? extends Observable<? extends U>> otherFactory)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Subscriber<? super T>
call(Subscriber<? super Observable<T>> child)
-
-
-
Field Detail
-
otherFactory
final Func0<? extends Observable<? extends U>> otherFactory
-
NEXT_SUBJECT
static final java.lang.Object NEXT_SUBJECT
Indicate the current subject should complete and a new subject be emitted.
-
NL
static final NotificationLite<java.lang.Object> NL
For error and completion indication.
-
-
Constructor Detail
-
OperatorWindowWithObservableFactory
public OperatorWindowWithObservableFactory(Func0<? extends Observable<? extends U>> otherFactory)
-
-
Method Detail
-
call
public Subscriber<? super T> call(Subscriber<? super Observable<T>> child)
-
-