Modifier and Type	Class and Description
pack-priv static class	CompletableFromCompletionStage.CompletionStageHandler<T>

Modifier and Type

Class and Description

pack-priv static class

CompletableFromCompletionStage.CompletionStageHandler<T>

Modifier and Type	Field and Description
pack-priv final CompletionStage<T>	stage

Modifier and Type

Field and Description

pack-priv final CompletionStage<T>

stage

Access	Constructor and Description
public	CompletableFromCompletionStage(CompletionStage<T> stage)

Access

Constructor and Description

public

CompletableFromCompletionStage(CompletionStage<T> stage)

Modifier and Type	Method and Description
protected void	subscribeActual(CompletableObserver observer)

Modifier and Type

Method and Description

protected void

subscribeActual(CompletableObserver observer)

stage	back to summary
pack-priv final CompletionStage<T> stage

stage

back to summary

pack-priv final CompletionStage<T> stage

CompletableFromCompletionStage	back to summary
public CompletableFromCompletionStage(CompletionStage<T> stage)

CompletableFromCompletionStage

back to summary

public CompletableFromCompletionStage(CompletionStage<T> stage)

subscribeActual	back to summary
protected void subscribeActual(CompletableObserver observer) Annotations @Override

subscribeActual

back to summary

protected void subscribeActual(CompletableObserver observer)

Annotations

@Override

io.reactivex.rxjava3.internal.jdk8 back to summary

pack-priv final Class CompletableFromCompletionStage.CompletionStageHandler<T>

Class Inheritance

extends Object
implements Disposable, BiConsumer<T, Throwable>

java.lang.Object
io.reactivex.rxjava3.internal.jdk8.CompletableFromCompletionStage.CompletionStageHandler

All Implemented Interfaces

java.util.function.BiConsumer, io.reactivex.rxjava3.disposables.Disposable

Field Summary

Modifier and Type	Field and Description
pack-priv final CompletableObserver	downstream
pack-priv final FlowableFromCompletionStage.BiConsumerAtomicReference<T>	whenReference

Constructor Summary

Access	Constructor and Description
pack-priv	CompletionStageHandler(CompletableObserver downstream, FlowableFromCompletionStage.BiConsumerAtomicReference<T> whenReference)

Method Summary

Modifier and Type	Method and Description
public void	accept(T the first input argument item, Throwable the second input argument error) Implements java.util.function.BiConsumer.accept. Performs this operation on the given arguments.
public void	dispose() Implements io.reactivex.rxjava3.disposables.Disposable.dispose. Dispose the resource, the operation should be idempotent.
public boolean	isDisposed() Implements io.reactivex.rxjava3.disposables.Disposable.isDisposed. Returns true if this resource has been disposed.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

downstream	back to summary
pack-priv final CompletableObserver downstream

whenReference	back to summary
pack-priv final FlowableFromCompletionStage.BiConsumerAtomicReference<T> whenReference

Constructor Detail

CompletionStageHandler	back to summary
pack-priv CompletionStageHandler(CompletableObserver downstream, FlowableFromCompletionStage.BiConsumerAtomicReference<T> whenReference)

Method Detail

accept	back to summary
public void accept(T item, Throwable error) Implements java.util.function.BiConsumer.accept. Doc from java.util.function.BiConsumer.accept. Performs this operation on the given arguments. Parameters item:T the first input argument error:Throwable the second input argument Annotations @Override

back to summary

public void accept(T item, Throwable error)

Implements java.util.function.BiConsumer.accept.

Doc from java.util.function.BiConsumer.accept.

Performs this operation on the given arguments.

Parameters

item:T: the first input argument
error:Throwable: the second input argument

Annotations

@Override

dispose	back to summary
public void dispose() Implements io.reactivex.rxjava3.disposables.Disposable.dispose. Doc from io.reactivex.rxjava3.disposables.Disposable.dispose. Dispose the resource, the operation should be idempotent. Annotations @Override

dispose

back to summary

public void dispose()

Implements io.reactivex.rxjava3.disposables.Disposable.dispose.

Doc from io.reactivex.rxjava3.disposables.Disposable.dispose.

Dispose the resource, the operation should be idempotent.

Annotations

@Override

isDisposed	back to summary
public boolean isDisposed() Implements io.reactivex.rxjava3.disposables.Disposable.isDisposed. Doc from io.reactivex.rxjava3.disposables.Disposable.isDisposed. Returns true if this resource has been disposed. Returns:boolean true if this resource has been disposed Annotations @Override

isDisposed

back to summary

public boolean isDisposed()

Implements io.reactivex.rxjava3.disposables.Disposable.isDisposed.

Doc from io.reactivex.rxjava3.disposables.Disposable.isDisposed.

Returns true if this resource has been disposed.

Returns:boolean

true if this resource has been disposed

Annotations