Package rx.internal.operators
Class OperatorWindowWithSize.WindowOverlap<T>
java.lang.Object
rx.Subscriber<T>
rx.internal.operators.OperatorWindowWithSize.WindowOverlap<T>
- All Implemented Interfaces:
Action
,Action0
,Function
,Observer<T>
,Subscription
- Enclosing class:
OperatorWindowWithSize<T>
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) final class
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final Subscriber
<? super Observable<T>> (package private) final Subscription
(package private) boolean
(package private) final AtomicInteger
(package private) Throwable
(package private) int
(package private) int
(package private) final AtomicLong
(package private) final int
(package private) final int
(package private) final ArrayDeque
<Subject<T, T>> (package private) final AtomicInteger
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
call()
(package private) boolean
checkTerminated
(boolean d, boolean empty, Subscriber<? super Subject<T, T>> a, Queue<Subject<T, T>> q) (package private) Producer
(package private) void
drain()
void
Notifies the Observer that theObservable
has finished sending push-based notifications.void
Notifies the Observer that theObservable
has experienced an error condition.void
Provides the Observer with a new item to observe.Methods inherited from class rx.Subscriber
add, isUnsubscribed, onStart, request, setProducer, unsubscribe
-
Field Details
-
actual
-
size
final int size -
skip
final int skip -
wip
-
cancel
-
windows
-
requested
-
drainWip
-
queue
-
error
Throwable error -
done
volatile boolean done -
index
int index -
produced
int produced
-
-
Constructor Details
-
WindowOverlap
-
-
Method Details
-
onNext
Description copied from interface:Observer
Provides the Observer with a new item to observe.The
Observable
may call this method 0 or more times.The
Observable
will not call this method again after it calls eitherObserver.onCompleted()
orObserver.onError(java.lang.Throwable)
. -
onError
Description copied from interface:Observer
Notifies the Observer that theObservable
has experienced an error condition.If the
Observable
calls this method, it will not thereafter callObserver.onNext(T)
orObserver.onCompleted()
. -
onCompleted
public void onCompleted()Description copied from interface:Observer
Notifies the Observer that theObservable
has finished sending push-based notifications.The
Observable
will not call this method if it callsObserver.onError(java.lang.Throwable)
.- Specified by:
onCompleted
in interfaceObserver<T>
-
createProducer
Producer createProducer() -
call
public void call() -
drain
void drain() -
checkTerminated
-