Package rx.internal.operators
Class OperatorWindowWithStartEndObservable<T,U,V>
- java.lang.Object
-
- rx.internal.operators.OperatorWindowWithStartEndObservable<T,U,V>
-
- Type Parameters:
T
- the value typeU
- the type of the window opening eventV
- 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.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) static class
OperatorWindowWithStartEndObservable.SerializedSubject<T>
Serialized access to the subject.(package private) class
OperatorWindowWithStartEndObservable.SourceSubscriber
-
Field Summary
Fields Modifier and Type Field Description (package private) Func1<? super U,? extends Observable<? extends V>>
windowClosingSelector
(package private) Observable<? extends U>
windowOpenings
-
Constructor Summary
Constructors Constructor Description OperatorWindowWithStartEndObservable(Observable<? extends U> windowOpenings, Func1<? super U,? extends Observable<? extends V>> windowClosingSelector)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Subscriber<? super T>
call(Subscriber<? super Observable<T>> child)
-
-
-
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)
-
-
Method Detail
-
call
public Subscriber<? super T> call(Subscriber<? super Observable<T>> child)
-
-