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

Modifier and Type

Class and Description

pack-priv static class

ObservableFromCompletionStage.BiConsumerAtomicReference<T>

pack-priv static class

ObservableFromCompletionStage.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	ObservableFromCompletionStage(CompletionStage<T> stage)

Access

Constructor and Description

public

ObservableFromCompletionStage(CompletionStage<T> stage)

Modifier and Type	Method and Description
protected void	subscribeActual(Observer<? super T> observer)

Modifier and Type

Method and Description

protected void

subscribeActual(Observer<? super T> observer)

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

stage

back to summary

pack-priv final CompletionStage<T> stage

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

ObservableFromCompletionStage

back to summary

public ObservableFromCompletionStage(CompletionStage<T> stage)

subscribeActual	back to summary
protected void subscribeActual(Observer<? super T> observer) Annotations @Override

subscribeActual

back to summary

protected void subscribeActual(Observer<? super T> observer)

Annotations

@Override

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

pack-priv final Class ObservableFromCompletionStage.BiConsumerAtomicReference<T>

Class Inheritance

extends AtomicReference<BiConsumer<T, Throwable>>
implements BiConsumer<T, Throwable>

java.lang.Object
java.util.concurrent.atomic.AtomicReference
io.reactivex.rxjava3.internal.jdk8.ObservableFromCompletionStage.BiConsumerAtomicReference

All Implemented Interfaces

java.util.function.BiConsumer

Field Summary

Modifier and Type	Field and Description
private static final long	serialVersionUID Hides java.util.concurrent.atomic.AtomicReference.serialVersionUID.

Constructor Summary

Access	Constructor and Description
pack-priv	BiConsumerAtomicReference()

Method Summary

Modifier and Type	Method and Description
public void	accept(T the first input argument t, Throwable the second input argument u) Implements java.util.function.BiConsumer.accept. Performs this operation on the given arguments.

Field Detail

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

Constructor Detail

BiConsumerAtomicReference	back to summary
pack-priv BiConsumerAtomicReference()

Method Detail

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

back to summary

public void accept(T t, Throwable u)

Implements java.util.function.BiConsumer.accept.

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

Performs this operation on the given arguments.

Parameters

t:T: the first input argument
u:Throwable: the second input argument

Annotations

@Override

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

pack-priv final Class ObservableFromCompletionStage.CompletionStageHandler<T>

Class Inheritance

extends DeferredScalarDisposable<T>
implements BiConsumer<T, Throwable>

java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicInteger
io.reactivex.rxjava3.internal.observers.BasicIntQueueDisposable
io.reactivex.rxjava3.internal.observers.DeferredScalarDisposable
io.reactivex.rxjava3.internal.jdk8.ObservableFromCompletionStage.CompletionStageHandler

All Implemented Interfaces

java.util.function.BiConsumer

Field Summary

Modifier and Type	Field and Description
private static final long	serialVersionUID Hides io.reactivex.rxjava3.internal.observers.DeferredScalarDisposable.serialVersionUID.
pack-priv final ObservableFromCompletionStage.BiConsumerAtomicReference<T>	whenReference

Inherited from io.reactivex.rxjava3.internal.observers.DeferredScalarDisposable:: downstream value

Constructor Summary

Access	Constructor and Description
pack-priv	CompletionStageHandler(Observer<? super T> downstream, ObservableFromCompletionStage.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() Overrides io.reactivex.rxjava3.internal.observers.DeferredScalarDisposable.dispose. Implements io.reactivex.rxjava3.disposables.Disposable.dispose. Dispose the resource, the operation should be idempotent.

Inherited from io.reactivex.rxjava3.internal.observers.DeferredScalarDisposable:: clear complete complete error isDisposed isEmpty poll requestFusion tryDispose

Field Detail

serialVersionUID	back to summary
private static final long serialVersionUID Hides io.reactivex.rxjava3.internal.observers.DeferredScalarDisposable.serialVersionUID.

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

Constructor Detail

CompletionStageHandler	back to summary
pack-priv CompletionStageHandler(Observer<? super T> downstream, ObservableFromCompletionStage.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() Overrides io.reactivex.rxjava3.internal.observers.DeferredScalarDisposable.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()

Overrides io.reactivex.rxjava3.internal.observers.DeferredScalarDisposable.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