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 java.lang.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 Classes Modifier and Type Class Description (package private) static class
OperatorWindowWithSize.WindowExact<T>
(package private) static class
OperatorWindowWithSize.WindowOverlap<T>
(package private) static class
OperatorWindowWithSize.WindowSkip<T>
-
Constructor Summary
Constructors Constructor Description OperatorWindowWithSize(int size, int skip)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Subscriber<? super T>
call(Subscriber<? super Observable<T>> child)
-
-
-
Method Detail
-
call
public Subscriber<? super T> call(Subscriber<? super Observable<T>> child)
- Specified by:
call
in interfaceFunc1<Subscriber<? super Observable<T>>,Subscriber<? super T>>
-
-