T
- the value typepublic final class SingleProducer<T> extends AtomicBoolean implements Producer
Constructor and Description |
---|
SingleProducer(Subscriber<? super T> child,
T value)
Constructs the producer with the given target child and value to be emitted.
|
Modifier and Type | Method and Description |
---|---|
void |
request(long n)
Request a certain maximum number of items from this Producer.
|
compareAndSet, get, getAndSet, lazySet, set, toString, weakCompareAndSet
public SingleProducer(Subscriber<? super T> child, T value)
child
- the child subscriber, non-nullvalue
- the value to be emitted, may be nullpublic void request(long n)
Producer
Long.MAX_VALUE
to this method.
Requests are additive but if a sequence of requests totals more than Long.MAX_VALUE
then
Long.MAX_VALUE
requests will be actioned and the extras may be ignored. Arriving at
Long.MAX_VALUE
by addition of requests cannot be assumed to disable backpressure. For example,
the code below may result in Long.MAX_VALUE
requests being actioned only.
request(100); request(Long.MAX_VALUE-1);
Copyright © 2017. All rights reserved.