Package rx.internal.operators
Class OperatorWindowWithSize<T>
java.lang.Object
rx.internal.operators.OperatorWindowWithSize<T>
- Type Parameters:
T
- the value type
- All Implemented Interfaces:
Func1<Subscriber<? super Observable<T>>,
,Subscriber<? super T>> Function
,Observable.Operator<Observable<T>,
T>
public final class OperatorWindowWithSize<T>
extends Object
implements Observable.Operator<Observable<T>,T>
Creates windows of values into the source sequence with skip frequency and size bounds.
If skip == size then the windows are non-overlapping, otherwise, windows may overlap
or can be discontinuous. The returned Observable sequence is cold and need to be
consumed while the window operation is in progress.
Note that this conforms the Rx.NET behavior, but does not match former RxJava behavior, which operated as a regular buffer and mapped its lists to Observables.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionSubscriber
<? super T> call
(Subscriber<? super Observable<T>> child)
-
Field Details
-
size
final int size -
skip
final int skip
-
-
Constructor Details
-
OperatorWindowWithSize
public OperatorWindowWithSize(int size, int skip)
-
-
Method Details
-
call
- Specified by:
call
in interfaceFunc1<Subscriber<? super Observable<T>>,
Subscriber<? super T>>
-