Class FlowableMapNotification.MapNotificationSubscriber<T,R>

java.lang.Object

java.lang.Number

java.util.concurrent.atomic.AtomicLong

io.reactivex.rxjava3.internal.subscribers.SinglePostCompleteSubscriber<T,R>

io.reactivex.rxjava3.internal.operators.flowable.FlowableMapNotification.MapNotificationSubscriber<T,R>

All Implemented Interfaces:

FlowableSubscriber<T>, Serializable, org.reactivestreams.Subscriber<T>, org.reactivestreams.Subscription

Enclosing class:

FlowableMapNotification<T,R>

static final class FlowableMapNotification.MapNotificationSubscriber<T,R>
extends SinglePostCompleteSubscriber<T,R>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final Supplier<? extends R>	onCompleteSupplier
(package private) final Function<? super Throwable, ? extends R>	onErrorMapper
(package private) final Function<? super T, ? extends R>	onNextMapper
private static final long	serialVersionUID

Fields inherited from class SinglePostCompleteSubscriber

downstream, produced, upstream, value

Constructor Summary

Constructors

Constructor	Description
MapNotificationSubscriber(org.reactivestreams.Subscriber<? super R> actual, Function<? super T, ? extends R> onNextMapper, Function<? super Throwable, ? extends R> onErrorMapper, Supplier<? extends R> onCompleteSupplier)

Method Summary

Modifier and Type	Method	Description
void	onComplete()
void	onError(Throwable t)
void	onNext(T t)

Methods inherited from class SinglePostCompleteSubscriber

cancel, complete, onDrop, onSubscribe, request

Methods inherited from class AtomicLong

accumulateAndGet, addAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, decrementAndGet, doubleValue, floatValue, get, getAcquire, getAndAccumulate, getAndAdd, getAndDecrement, getAndIncrement, getAndSet, getAndUpdate, getOpaque, getPlain, incrementAndGet, intValue, lazySet, longValue, set, setOpaque, setPlain, setRelease, toString, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile

Methods inherited from class Number

byteValue, shortValue

Methods inherited from class Object

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

Field Details

serialVersionUID

private static final long serialVersionUID

See Also:

• Constant Field Values

onNextMapper

final Function<? super T, ? extends R> onNextMapper

onErrorMapper

final Function<? super Throwable, ? extends R> onErrorMapper

onCompleteSupplier

final Supplier<? extends R> onCompleteSupplier

Constructor Details

MapNotificationSubscriber

MapNotificationSubscriber(org.reactivestreams.Subscriber<? super R> actual,
 Function<? super T, ? extends R> onNextMapper,
 Function<? super Throwable, ? extends R> onErrorMapper,
 Supplier<? extends R> onCompleteSupplier)

Method Details

onNext

public void onNext(T t)

onError

public void onError(Throwable t)

onComplete

public void onComplete()