T
- the value typepublic final class InnerQueuedSubscriber<T> extends AtomicReference<org.reactivestreams.Subscription> implements FlowableSubscriber<T>, org.reactivestreams.Subscription
Constructor and Description |
---|
InnerQueuedSubscriber(InnerQueuedSubscriberSupport<T> parent,
int prefetch) |
Modifier and Type | Method and Description |
---|---|
void |
cancel() |
boolean |
isDone() |
void |
onComplete() |
void |
onError(Throwable t) |
void |
onNext(T t) |
void |
onSubscribe(org.reactivestreams.Subscription s)
Implementors of this method should make sure everything that needs
to be visible in
Subscriber.onNext(Object) is established before
calling Subscription.request(long) . |
SimpleQueue<T> |
queue() |
void |
request(long n) |
void |
requestOne() |
void |
setDone() |
accumulateAndGet, compareAndSet, get, getAndAccumulate, getAndSet, getAndUpdate, lazySet, set, toString, updateAndGet, weakCompareAndSet
public InnerQueuedSubscriber(InnerQueuedSubscriberSupport<T> parent, int prefetch)
public void onSubscribe(org.reactivestreams.Subscription s)
FlowableSubscriber
Subscriber.onNext(Object)
is established before
calling Subscription.request(long)
. In practice this means
no initialization should happen after the request()
call and
additional behavior is thread safe in respect to onNext
.
onSubscribe
in interface FlowableSubscriber<T>
onSubscribe
in interface org.reactivestreams.Subscriber<T>
public void onError(Throwable t)
onError
in interface org.reactivestreams.Subscriber<T>
public void onComplete()
onComplete
in interface org.reactivestreams.Subscriber<T>
public void request(long n)
request
in interface org.reactivestreams.Subscription
public void requestOne()
public void cancel()
cancel
in interface org.reactivestreams.Subscription
public boolean isDone()
public void setDone()
public SimpleQueue<T> queue()
Copyright © 2018 JBoss by Red Hat. All rights reserved.