Package rx.internal.operators
Class OperatorWindowWithSize.WindowOverlap.WindowOverlapProducer
java.lang.Object
java.util.concurrent.atomic.AtomicBoolean
rx.internal.operators.OperatorWindowWithSize.WindowOverlap.WindowOverlapProducer
- All Implemented Interfaces:
Serializable
,Producer
- Enclosing class:
OperatorWindowWithSize.WindowOverlap<T>
final class OperatorWindowWithSize.WindowOverlap.WindowOverlapProducer
extends AtomicBoolean
implements Producer
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
request
(long n) Request a certain maximum number of items from this Producer.Methods inherited from class java.util.concurrent.atomic.AtomicBoolean
compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, get, getAcquire, getAndSet, getOpaque, getPlain, lazySet, set, setOpaque, setPlain, setRelease, toString, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile
-
Field Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
-
Constructor Details
-
WindowOverlapProducer
WindowOverlapProducer()
-
-
Method Details
-
request
public void request(long n) Description copied from interface:Producer
Request a certain maximum number of items from this Producer. This is a way of requesting backpressure. To disable backpressure, passLong.MAX_VALUE
to this method.Requests are additive but if a sequence of requests totals more than
Long.MAX_VALUE
thenLong.MAX_VALUE
requests will be actioned and the extras may be ignored. Arriving atLong.MAX_VALUE
by addition of requests cannot be assumed to disable backpressure. For example, the code below may result inLong.MAX_VALUE
requests being actioned only.request(100); request(Long.MAX_VALUE-1);
-