public final Class FlowableLastStageSubscriber<T>

Class Inheritance

extends FlowableStageSubscriber<T>

java.lang.Object
java.util.concurrent.CompletableFuture
io.reactivex.rxjava3.internal.jdk8.FlowableStageSubscriber
io.reactivex.rxjava3.internal.jdk8.FlowableLastStageSubscriber

Type Parameters

<T>: the element type

Imports

java.util.NoSuchElementException, org.reactivestreams.Subscription

Signals the last element of the source via the underlying CompletableFuture, signals the a default item if the upstream is empty or signals NoSuchElementException.

Since: 3.0.0

Field Summary

Modifier and Type	Field and Description
pack-priv final T	defaultItem
pack-priv final boolean	hasDefault

Inherited from io.reactivex.rxjava3.internal.jdk8.FlowableStageSubscriber:: upstream value

Constructor Summary

Access	Constructor and Description
public	FlowableLastStageSubscriber(boolean hasDefault, T defaultItem)

Method Summary

Modifier and Type	Method and Description
protected void	afterSubscribe(Subscription s) Implements abstract io.reactivex.rxjava3.internal.jdk8.FlowableStageSubscriber.afterSubscribe.
public void	onComplete() Implements org.reactivestreams.Subscriber.onComplete. Successful terminal state.
public void	onNext(T the element signaled t) Implements org.reactivestreams.Subscriber.onNext. Data notification sent by the `Publisher` in response to requests to `Subscription#request(long)`.

Inherited from io.reactivex.rxjava3.internal.jdk8.FlowableStageSubscriber:: cancel cancelUpstream clear complete completeExceptionally onError onSubscribe

Field Detail

defaultItem	back to summary
pack-priv final T defaultItem

hasDefault	back to summary
pack-priv final boolean hasDefault

Constructor Detail

FlowableLastStageSubscriber	back to summary
public FlowableLastStageSubscriber(boolean hasDefault, T defaultItem)

Method Detail

afterSubscribe	back to summary
protected void afterSubscribe(Subscription s) Implements abstract io.reactivex.rxjava3.internal.jdk8.FlowableStageSubscriber.afterSubscribe. Annotations @Override

afterSubscribe

back to summary

protected void afterSubscribe(Subscription s)

Implements abstract io.reactivex.rxjava3.internal.jdk8.FlowableStageSubscriber.afterSubscribe.

Annotations

@Override

onComplete back to summary

onComplete	back to summary
public void onComplete() Implements org.reactivestreams.Subscriber.onComplete. Doc from org.reactivestreams.Subscriber.onComplete. Successful terminal state. No further events will be sent even if `Subscription#request(long)` is invoked again. Annotations @Override

public void onComplete()

Implements org.reactivestreams.Subscriber.onComplete.

Doc from org.reactivestreams.Subscriber.onComplete.

Successful terminal state.

No further events will be sent even if Subscription#request(long) is invoked again.

Annotations

@Override

onNext back to summary

onNext	back to summary
public void onNext(T t) Implements org.reactivestreams.Subscriber.onNext. Doc from org.reactivestreams.Subscriber.onNext. Data notification sent by the `Publisher` in response to requests to `Subscription#request(long)`. Parameters t:T the element signaled Annotations @Override

public void onNext(T t)

Implements org.reactivestreams.Subscriber.onNext.

Doc from org.reactivestreams.Subscriber.onNext.

Data notification sent by the Publisher in response to requests to Subscription#request(long).

Parameters

t:T: the element signaled

Annotations

@Override