Class ObservableFromCompletionStage.BiConsumerAtomicReference<T>

java.lang.Object

java.util.concurrent.atomic.AtomicReference<BiConsumer<T, Throwable>>

io.reactivex.rxjava3.internal.jdk8.ObservableFromCompletionStage.BiConsumerAtomicReference<T>

All Implemented Interfaces:

Serializable, BiConsumer<T, Throwable>

Enclosing class:

ObservableFromCompletionStage<T>

static final class ObservableFromCompletionStage.BiConsumerAtomicReference<T>
extends AtomicReference<BiConsumer<T, Throwable>>
implements BiConsumer<T, Throwable>

Since:

3.0.0

Field Summary

Fields

Modifier and Type	Field	Description
private static final long	serialVersionUID

Constructor Summary

Constructors

Constructor	Description
BiConsumerAtomicReference()

Method Summary

Modifier and Type	Method	Description
void	accept(T t, Throwable u)

Methods inherited from class AtomicReference

accumulateAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, get, getAcquire, getAndAccumulate, getAndSet, getAndUpdate, getOpaque, getPlain, lazySet, set, setOpaque, setPlain, setRelease, toString, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface BiConsumer

andThen

Field Details

serialVersionUID

private static final long serialVersionUID

See Also:

• Constant Field Values

Constructor Details

BiConsumerAtomicReference

BiConsumerAtomicReference()

Method Details

accept

public void accept(T t,
 Throwable u)

Specified by:

accept in interface BiConsumer<T, Throwable>