Top Inners Fields Constructors Methods

io.reactivex.rxjava3.internal.operators.flowable

public final Class FlowableOnBackpressureReduce<T>

Class Inheritance

extends AbstractFlowableWithUpstream<T, T>

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

Imports

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

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv static class	FlowableOnBackpressureReduce.BackpressureReduceSubscriber<T>

Field Summary

Modifier and Type	Field and Description
pack-priv final BiFunction<T, T, T>	reducer

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

Constructor Summary

Access	Constructor and Description
public	FlowableOnBackpressureReduce(@NonNull Flowable<T> source, @NonNull BiFunction<T, T, T> reducer)

Method Summary

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

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

Field Detail

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

Constructor Detail

FlowableOnBackpressureReduce	back to summary
public FlowableOnBackpressureReduce(@NonNull Flowable<T> source, @NonNull BiFunction<T, T, T> reducer)

Method Detail

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

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

pack-priv final Class FlowableOnBackpressureReduce.BackpressureReduceSubscriber<T>

Class Inheritance

extends AbstractBackpressureThrottlingSubscriber<T, T>

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

Field Summary

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

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

Constructor Summary

Access	Constructor and Description
pack-priv	BackpressureReduceSubscriber(@NonNull Subscriber<? super T> downstream, @NonNull BiFunction<T, T, T> 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<T, T, T> reducer

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

Constructor Detail

BackpressureReduceSubscriber	back to summary
pack-priv BackpressureReduceSubscriber(@NonNull Subscriber<? super T> downstream, @NonNull BiFunction<T, T, T> 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