Class FlowableSampleTimed.SampleTimedEmitLast<T>

java.lang.Object

java.util.concurrent.atomic.AtomicReference<T>

io.reactivex.rxjava3.internal.operators.flowable.FlowableSampleTimed.SampleTimedSubscriber<T>

io.reactivex.rxjava3.internal.operators.flowable.FlowableSampleTimed.SampleTimedEmitLast<T>

All Implemented Interfaces:

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

Enclosing class:

FlowableSampleTimed<T>

static final class FlowableSampleTimed.SampleTimedEmitLast<T>
extends FlowableSampleTimed.SampleTimedSubscriber<T>

Field Summary

Fields

Modifier and Type	Field	Description
private static final long	serialVersionUID
(package private) final AtomicInteger	wip

Fields inherited from class FlowableSampleTimed.SampleTimedSubscriber

downstream, onDropped, period, requested, scheduler, timer, unit, upstream

Constructor Summary

Constructors

Constructor	Description
SampleTimedEmitLast(org.reactivestreams.Subscriber<? super T> actual, long period, TimeUnit unit, Scheduler scheduler, Consumer<? super T> onDropped)

Method Summary

Modifier and Type	Method	Description
(package private) void	complete()
void	run()

Methods inherited from class FlowableSampleTimed.SampleTimedSubscriber

cancel, cancelTimer, emit, onComplete, onError, onNext, onSubscribe, request

Methods inherited from class AtomicReference

accumulateAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, get, getAcquire, getAndAccumulate, getAndSet, getAndUpdate, getOpaque, getPlain, lazySet, set, setOpaque, setPlain, setRelease, toString, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile

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

wip

final AtomicInteger wip

Constructor Details

SampleTimedEmitLast

SampleTimedEmitLast(org.reactivestreams.Subscriber<? super T> actual,
 long period,
 TimeUnit unit,
 Scheduler scheduler,
 Consumer<? super T> onDropped)

Method Details

complete

void complete()

Specified by:

complete in class FlowableSampleTimed.SampleTimedSubscriber<T>

run

public void run()