Top Inners Fields Constructors Methods

io.reactivex.rxjava3.internal.operators.flowable

public final Class FlowableOnBackpressureReduceWith<T, R>

Class Inheritance

extends AbstractFlowableWithUpstream<T, R>

java.lang.Object
io.reactivex.rxjava3.core.Flowable
io.reactivex.rxjava3.internal.operators.flowable.AbstractFlowableWithUpstream
io.reactivex.rxjava3.internal.operators.flowable.FlowableOnBackpressureReduceWith

Imports

io.reactivex.rxjava3.annotations.NonNull, io.reactivex.rxjava3.core.Flowable, io.reactivex.rxjava3.exceptions.Exceptions, io.reactivex.rxjava3.functions.BiFunction, .Supplier, org.reactivestreams.Subscriber, java.util.Objects

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv static class	FlowableOnBackpressureReduceWith.BackpressureReduceWithSubscriber<T, R>

Field Summary

Modifier and Type	Field and Description
pack-priv final BiFunction<R, ? super T, R>	reducer
pack-priv final Supplier<R>	supplier

Inherited from io.reactivex.rxjava3.internal.operators.flowable.AbstractFlowableWithUpstream:: source

Constructor Summary

Access	Constructor and Description
public	FlowableOnBackpressureReduceWith(@NonNull Flowable<T> source, @NonNull Supplier<R> supplier, @NonNull BiFunction<R, ? super T, R> reducer)

Method Summary

Modifier and Type	Method and Description
protected void	subscribeActual(@NonNull Subscriber<? super R> s)

Inherited from io.reactivex.rxjava3.internal.operators.flowable.AbstractFlowableWithUpstream:: source

Field Detail

reducer	back to summary
pack-priv final BiFunction<R, ? super T, R> reducer

supplier	back to summary
pack-priv final Supplier<R> supplier

Constructor Detail

FlowableOnBackpressureReduceWith	back to summary
public FlowableOnBackpressureReduceWith(@NonNull Flowable<T> source, @NonNull Supplier<R> supplier, @NonNull BiFunction<R, ? super T, R> reducer)

Method Detail

subscribeActual	back to summary
protected void subscribeActual(@NonNull Subscriber<? super R> s) Annotations @Override

io.reactivex.rxjava3.internal.operators.flowable back to summary

pack-priv final Class FlowableOnBackpressureReduceWith.BackpressureReduceWithSubscriber<T, R>

Class Inheritance

extends AbstractBackpressureThrottlingSubscriber<T, R>

java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicInteger
io.reactivex.rxjava3.internal.operators.flowable.AbstractBackpressureThrottlingSubscriber
io.reactivex.rxjava3.internal.operators.flowable.FlowableOnBackpressureReduceWith.BackpressureReduceWithSubscriber

Field Summary

Modifier and Type	Field and Description
pack-priv final BiFunction<R, ? super T, R>	reducer
private static final long	serialVersionUID Hides io.reactivex.rxjava3.internal.operators.flowable.AbstractBackpressureThrottlingSubscriber.serialVersionUID.
pack-priv final Supplier<R>	supplier

Inherited from io.reactivex.rxjava3.internal.operators.flowable.AbstractBackpressureThrottlingSubscriber:: cancelled current done downstream error requested upstream

Constructor Summary

Access	Constructor and Description
pack-priv	BackpressureReduceWithSubscriber(@NonNull Subscriber<? super R> downstream, @NonNull Supplier<R> supplier, @NonNull BiFunction<R, ? super T, R> reducer)

Method Summary

Modifier and Type	Method and Description
public void	onNext(T the element signaled t) Implements abstract io.reactivex.rxjava3.internal.operators.flowable.AbstractBackpressureThrottlingSubscriber.onNext. Implements org.reactivestreams.Subscriber.onNext. Data notification sent by the `Publisher` in response to requests to `Subscription#request(long)`.

Inherited from io.reactivex.rxjava3.internal.operators.flowable.AbstractBackpressureThrottlingSubscriber:: cancel checkTerminated drain onComplete onError onSubscribe request

Field Detail

reducer	back to summary
pack-priv final BiFunction<R, ? super T, R> reducer

serialVersionUID	back to summary
private static final long serialVersionUID Hides io.reactivex.rxjava3.internal.operators.flowable.AbstractBackpressureThrottlingSubscriber.serialVersionUID.

supplier	back to summary
pack-priv final Supplier<R> supplier

Constructor Detail

BackpressureReduceWithSubscriber	back to summary
pack-priv BackpressureReduceWithSubscriber(@NonNull Subscriber<? super R> downstream, @NonNull Supplier<R> supplier, @NonNull BiFunction<R, ? super T, R> reducer)

Method Detail

onNext back to summary

public void onNext(T t)

Implements abstract io.reactivex.rxjava3.internal.operators.flowable.AbstractBackpressureThrottlingSubscriber.onNext.

Implements org.reactivestreams.Subscriber.onNext.

Doc from org.reactivestreams.Subscriber.onNext.

Data notification sent by the Publisher in response to requests to Subscription#request(long).

Parameters

t:T: the element signaled

Annotations

@Override