Package rx.internal.operators
Class OperatorWindowWithTime.CountedSerializedSubject<T>
- java.lang.Object
-
- rx.internal.operators.OperatorWindowWithTime.CountedSerializedSubject<T>
-
- Type Parameters:
T
- the subject's in-out type
- Enclosing class:
- OperatorWindowWithTime<T>
static final class OperatorWindowWithTime.CountedSerializedSubject<T> extends java.lang.Object
Record to store the subject and the emission count.
-
-
Constructor Summary
Constructors Constructor Description CountedSerializedSubject(Observer<T> consumer, Observable<T> producer)
-
-
-
Field Detail
-
producer
final Observable<T> producer
-
count
int count
-
-
Constructor Detail
-
CountedSerializedSubject
public CountedSerializedSubject(Observer<T> consumer, Observable<T> producer)
-
-