Package rx.internal.operators
Class OperatorWindowWithTime.State<T>
- java.lang.Object
-
- rx.internal.operators.OperatorWindowWithTime.State<T>
-
- Enclosing class:
- OperatorWindowWithTime<T>
static final class OperatorWindowWithTime.State<T> extends java.lang.Object
The immutable windowing state with one subject.
-
-
Field Summary
Fields Modifier and Type Field Description (package private) Observer<T>
consumer
(package private) int
count
(package private) static OperatorWindowWithTime.State<java.lang.Object>
EMPTY
(package private) Observable<T>
producer
-
Constructor Summary
Constructors Constructor Description State(Observer<T> consumer, Observable<T> producer, int count)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description OperatorWindowWithTime.State<T>
clear()
OperatorWindowWithTime.State<T>
create(Observer<T> consumer, Observable<T> producer)
static <T> OperatorWindowWithTime.State<T>
empty()
OperatorWindowWithTime.State<T>
next()
-
-
-
Field Detail
-
producer
final Observable<T> producer
-
count
final int count
-
EMPTY
static final OperatorWindowWithTime.State<java.lang.Object> EMPTY
-
-
Constructor Detail
-
State
public State(Observer<T> consumer, Observable<T> producer, int count)
-
-
Method Detail
-
next
public OperatorWindowWithTime.State<T> next()
-
create
public OperatorWindowWithTime.State<T> create(Observer<T> consumer, Observable<T> producer)
-
clear
public OperatorWindowWithTime.State<T> clear()
-
empty
public static <T> OperatorWindowWithTime.State<T> empty()
-
-