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 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 ClassesModifier and TypeClassDescription(package private) static final class
Serialized access to the subject.(package private) final class
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final Func1
<? super U, ? extends Observable<? extends V>> (package private) final Observable
<? extends U> -
Constructor Summary
ConstructorsConstructorDescriptionOperatorWindowWithStartEndObservable
(Observable<? extends U> windowOpenings, Func1<? super U, ? extends Observable<? extends V>> windowClosingSelector) -
Method Summary
Modifier and TypeMethodDescriptionSubscriber
<? super T> call
(Subscriber<? super Observable<T>> child)
-
Field Details
-
windowOpenings
-
windowClosingSelector
-
-
Constructor Details
-
OperatorWindowWithStartEndObservable
public OperatorWindowWithStartEndObservable(Observable<? extends U> windowOpenings, Func1<? super U, ? extends Observable<? extends V>> windowClosingSelector)
-
-
Method Details