Package rx.internal.operators

Class OperatorWindowWithObservable<T,U>

java.lang.Object

rx.internal.operators.OperatorWindowWithObservable<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 OperatorWindowWithObservable<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 Classes

Modifier and Type	Class	Description
(package private) static final class	OperatorWindowWithObservable.BoundarySubscriber<T,U>	Observes the boundary.
(package private) static final class	OperatorWindowWithObservable.SourceSubscriber<T>	Observes the source.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static final Object	NEXT_SUBJECT	Indicate the current subject should complete and a new subject be emitted.
(package private) static final NotificationLite<Object>	NL	For error and completion indication.
(package private) final Observable<U>	other

Constructor Summary

Constructors

Constructor	Description
OperatorWindowWithObservable(Observable<U> other)

Method Summary

Modifier and Type	Method	Description
Subscriber<? super T>	call(Subscriber<? super Observable<T>> child)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

other

final Observable<U> other

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

OperatorWindowWithObservable

public OperatorWindowWithObservable(Observable<U> other)

Method Details

call

public Subscriber<? super T> call(Subscriber<? super Observable<T>> child)

Specified by:

call in interface Func1<T,U>