Top Inners Fields Constructors Methods

io.reactivex.rxjava3.internal.operators.flowable

public final Class FlowableOnBackpressureLatest<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.FlowableOnBackpressureLatest

Imports

io.reactivex.rxjava3.core.Flowable, io.reactivex.rxjava3.exceptions.Exceptions, io.reactivex.rxjava3.functions.Consumer, org.reactivestreams.Subscriber

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv static class	FlowableOnBackpressureLatest.BackpressureLatestSubscriber<T>

Field Summary

Modifier and Type	Field and Description
pack-priv final Consumer<? super T>	onDropped

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

Constructor Summary

Access	Constructor and Description
public	FlowableOnBackpressureLatest(Flowable<T> source, Consumer<? super T> onDropped)

Method Summary

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

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

Field Detail

onDropped	back to summary
pack-priv final Consumer<? super T> onDropped

Constructor Detail

FlowableOnBackpressureLatest	back to summary
public FlowableOnBackpressureLatest(Flowable<T> source, Consumer<? super T> onDropped)

Method Detail

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

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

pack-priv final Class FlowableOnBackpressureLatest.BackpressureLatestSubscriber<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.FlowableOnBackpressureLatest.BackpressureLatestSubscriber

Field Summary

Modifier and Type	Field and Description
pack-priv final Consumer<? super T>	onDropped
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	BackpressureLatestSubscriber(Subscriber<? super T> downstream, Consumer<? super T> onDropped)

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

onDropped	back to summary
pack-priv final Consumer<? super T> onDropped

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

Constructor Detail

BackpressureLatestSubscriber	back to summary
pack-priv BackpressureLatestSubscriber(Subscriber<? super T> downstream, Consumer<? super T> onDropped)

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