Class FlowableOnBackpressureReduceWith.BackpressureReduceWithSubscriber<T,R>

java.lang.Object

java.lang.Number

java.util.concurrent.atomic.AtomicInteger

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

io.reactivex.rxjava3.internal.operators.flowable.FlowableOnBackpressureReduceWith.BackpressureReduceWithSubscriber<T,R>

All Implemented Interfaces:

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

Enclosing class:

FlowableOnBackpressureReduceWith<T,R>

static final class FlowableOnBackpressureReduceWith.BackpressureReduceWithSubscriber<T,R>
extends AbstractBackpressureThrottlingSubscriber<T,R>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final BiFunction<R, ? super T, R>	reducer
private static final long	serialVersionUID
(package private) final Supplier<R>	supplier

Fields inherited from class AbstractBackpressureThrottlingSubscriber

cancelled, current, done, downstream, error, requested, upstream

Constructor Summary

Constructors

Constructor	Description
BackpressureReduceWithSubscriber(@NonNull org.reactivestreams.Subscriber<? super R> downstream, @NonNull Supplier<R> supplier, @NonNull BiFunction<R, ? super T, R> reducer)

Method Summary

Modifier and Type	Method	Description
void	onNext(T t)

Methods inherited from class AbstractBackpressureThrottlingSubscriber

cancel, checkTerminated, drain, onComplete, onError, onSubscribe, request

Methods inherited from class AtomicInteger

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

reducer

final BiFunction<R, ? super T, R> reducer

supplier

final Supplier<R> supplier

Constructor Details

BackpressureReduceWithSubscriber

BackpressureReduceWithSubscriber(@NonNull
 @NonNull org.reactivestreams.Subscriber<? super R> downstream,
 @NonNull
 @NonNull Supplier<R> supplier,
 @NonNull
 @NonNull BiFunction<R, ? super T, R> reducer)

Method Details

onNext

public void onNext(T t)

Specified by:

onNext in interface org.reactivestreams.Subscriber<T>

Specified by:

onNext in class AbstractBackpressureThrottlingSubscriber<T,R>