RxJava 2 2.2.21 · io.reactivex.internal.subscribers.SinglePostCompleteSubscriber

Modifier and Type	Field and Description
pack-priv static final long	COMPLETE_MASK Masks out the 2^63 bit indicating a completed state.
protected final Subscriber<? super R>	downstream The downstream consumer.
protected long	produced Number of values emitted so far.
pack-priv static final long	REQUEST_MASK Masks out the lower 63 bit holding the current request amount.
private static final long	serialVersionUID Hides java.util.concurrent.atomic.AtomicLong.serialVersionUID.
protected Subscription	upstream The upstream subscription.
protected R	value Hides java.util.concurrent.atomic.AtomicLong.value. The last value stored in case there is no request for it.

Access	Constructor and Description
public	SinglePostCompleteSubscriber(Subscriber<? super R> downstream)

Method Summary

Modifier and Type	Method and Description
public void	cancel() Implements org.reactivestreams.Subscription.cancel. Request the `Publisher` to stop sending data and clean up resources.
protected final void	complete(R the value to emit n) Signals the given value and an onComplete if the downstream is ready to receive the final value.
protected void	onDrop(R the value dropped n) Called in case of multiple calls to complete.
public void	onSubscribe(Subscription the `Subscription` that allows requesting data via `Subscription#request(long)` s) Implements io.reactivex.FlowableSubscriber.onSubscribe. Implementors of this method should make sure everything that needs to be visible in `onNext(Object)` is established before calling `Subscription#request(long)`.
public final void	request(long the strictly positive number of elements to requests to the upstream `Publisher` n) Implements org.reactivestreams.Subscription.request. No events will be sent by a `Publisher` until demand is signaled via this method.

Field Detail

COMPLETE_MASK	back to summary
pack-priv static final long COMPLETE_MASK Masks out the 2^63 bit indicating a completed state.

downstream	back to summary
protected final Subscriber<? super R> downstream The downstream consumer.

produced	back to summary
protected long produced Number of values emitted so far.

REQUEST_MASK	back to summary
pack-priv static final long REQUEST_MASK Masks out the lower 63 bit holding the current request amount.

serialVersionUID	back to summary
private static final long serialVersionUID Hides java.util.concurrent.atomic.AtomicLong.serialVersionUID.

upstream	back to summary
protected Subscription upstream The upstream subscription.

value	back to summary
protected R value Hides java.util.concurrent.atomic.AtomicLong.value. The last value stored in case there is no request for it.

value

back to summary

protected R value

Hides java.util.concurrent.atomic.AtomicLong.value.

The last value stored in case there is no request for it.

Constructor Detail

SinglePostCompleteSubscriber	back to summary
public SinglePostCompleteSubscriber(Subscriber<? super R> downstream)

Method Detail

cancel back to summary

cancel	back to summary
public void cancel() Implements org.reactivestreams.Subscription.cancel. Doc from org.reactivestreams.Subscription.cancel. Request the `Publisher` to stop sending data and clean up resources. Data may still be sent to meet previously signalled demand after calling cancel. Annotations @Override

public void cancel()

Implements org.reactivestreams.Subscription.cancel.

Doc from org.reactivestreams.Subscription.cancel.

Request the Publisher to stop sending data and clean up resources.

Data may still be sent to meet previously signalled demand after calling cancel.

Annotations

@Override

complete	back to summary
protected final void complete(R n) Signals the given value and an onComplete if the downstream is ready to receive the final value. Parameters n:R the value to emit

complete

back to summary

protected final void complete(R n)

Signals the given value and an onComplete if the downstream is ready to receive the final value.

Parameters

n:R: the value to emit

onDrop	back to summary
protected void onDrop(R n) Called in case of multiple calls to complete. Parameters n:R the value dropped

onDrop

back to summary

protected void onDrop(R n)

Called in case of multiple calls to complete.

Parameters

n:R: the value dropped

onSubscribe back to summary

onSubscribe	back to summary
public void onSubscribe(Subscription s) Implements io.reactivex.FlowableSubscriber.onSubscribe. Doc from io.reactivex.FlowableSubscriber.onSubscribe. Implementors of this method should make sure everything that needs to be visible in `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`. Invoked after calling `Publisher#subscribe(Subscriber)`. No data will start flowing until `Subscription#request(long)` is invoked. It is the responsibility of this `Subscriber` instance to call `Subscription#request(long)` whenever more data is wanted. The `Publisher` will send notifications only in response to `Subscription#request(long)`. Parameters s:Subscription Doc from org.reactivestreams.Subscriber.onSubscribe. the `Subscription` that allows requesting data via `Subscription#request(long)` Annotations @Override

public void onSubscribe(Subscription s)

Implements io.reactivex.FlowableSubscriber.onSubscribe.

Doc from io.reactivex.FlowableSubscriber.onSubscribe.

Implementors of this method should make sure everything that needs to be visible in 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. Invoked after calling Publisher#subscribe(Subscriber).

No data will start flowing until Subscription#request(long) is invoked.

It is the responsibility of this Subscriber instance to call Subscription#request(long) whenever more data is wanted.

The Publisher will send notifications only in response to Subscription#request(long).

Parameters

s:Subscription

Doc from org.reactivestreams.Subscriber.onSubscribe.

the Subscription that allows requesting data via Subscription#request(long)

Annotations

@Override

request back to summary

request	back to summary
public final void request(long n) Implements org.reactivestreams.Subscription.request. Doc from org.reactivestreams.Subscription.request. No events will be sent by a `Publisher` until demand is signaled via this method. It can be called however often and whenever needed—but if the outstanding cumulative demand ever becomes Long.MAX_VALUE or more, it may be treated by the `Publisher` as "effectively unbounded". Whatever has been requested can be sent by the `Publisher` so only signal demand for what can be safely handled. A `Publisher` can send less than is requested if the stream ends but then must emit either `Subscriber#onError(Throwable)` or `Subscriber#onComplete()`. Parameters n:long the strictly positive number of elements to requests to the upstream `Publisher` Annotations @Override

public final void request(long n)

Implements org.reactivestreams.Subscription.request.

Doc from org.reactivestreams.Subscription.request.

No events will be sent by a Publisher until demand is signaled via this method.

It can be called however often and whenever needed—but if the outstanding cumulative demand ever becomes Long.MAX_VALUE or more, it may be treated by the Publisher as "effectively unbounded".

Whatever has been requested can be sent by the Publisher so only signal demand for what can be safely handled.

A Publisher can send less than is requested if the stream ends but then must emit either Subscriber#onError(Throwable) or Subscriber#onComplete().

Parameters

n:long: the strictly positive number of elements to requests to the upstream Publisher

Annotations

@Override

public abstract Class SinglePostCompleteSubscriber<T, R>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail