Package io.reactivex.rxjava3.internal.operators.flowable

Class FlowableWindowTimed.AbstractWindowSubscriber<T>

java.lang.Object

java.lang.Number

java.util.concurrent.atomic.AtomicInteger

io.reactivex.rxjava3.internal.operators.flowable.FlowableWindowTimed.AbstractWindowSubscriber<T>

All Implemented Interfaces:

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

Direct Known Subclasses:

FlowableWindowTimed.WindowExactBoundedSubscriber, FlowableWindowTimed.WindowExactUnboundedSubscriber, FlowableWindowTimed.WindowSkipSubscriber

Enclosing class:

FlowableWindowTimed<T>

abstract static class FlowableWindowTimed.AbstractWindowSubscriber<T>
extends AtomicInteger
implements FlowableSubscriber<T>, org.reactivestreams.Subscription

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final int	bufferSize
(package private) boolean	done
(package private) final org.reactivestreams.Subscriber<? super Flowable<T>>	downstream
(package private) final AtomicBoolean	downstreamCancelled
(package private) long	emitted
(package private) Throwable	error
(package private) final SimplePlainQueue<Object>	queue
(package private) final AtomicLong	requested
private static final long	serialVersionUID
(package private) final long	timespan
(package private) final TimeUnit	unit
(package private) org.reactivestreams.Subscription	upstream
(package private) boolean	upstreamCancelled
(package private) final AtomicInteger	windowCount

Constructor Summary

Constructors

Constructor	Description
AbstractWindowSubscriber(org.reactivestreams.Subscriber<? super Flowable<T>> downstream, long timespan, TimeUnit unit, int bufferSize)

Method Summary

Modifier and Type	Method	Description
final void	cancel()
(package private) abstract void	cleanupResources()
(package private) abstract void	createFirstWindow()
(package private) abstract void	drain()
final void	onComplete()
final void	onError(Throwable t)
final void	onNext(T t)
final void	onSubscribe(org.reactivestreams.Subscription s)	Implementors of this method should make sure everything that needs to be visible in Subscriber.onNext(Object) is established before calling Subscription.request(long).
final void	request(long n)
(package private) final void	windowDone()

Methods inherited from class java.util.concurrent.atomic.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 java.lang.Number

byteValue, shortValue

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

serialVersionUID

private static final long serialVersionUID

See Also:

• Constant Field Values

downstream

final org.reactivestreams.Subscriber<? super Flowable<T>> downstream

queue

final SimplePlainQueue<Object> queue

timespan

final long timespan

unit

final TimeUnit unit

bufferSize

final int bufferSize

requested

final AtomicLong requested

emitted

long emitted

done

volatile boolean done

error

Throwable error

upstream

org.reactivestreams.Subscription upstream

downstreamCancelled

final AtomicBoolean downstreamCancelled

upstreamCancelled

volatile boolean upstreamCancelled

windowCount

final AtomicInteger windowCount

Constructor Details

AbstractWindowSubscriber

AbstractWindowSubscriber(org.reactivestreams.Subscriber<? super Flowable<T>> downstream,
 long timespan,
 TimeUnit unit,
 int bufferSize)

Method Details

onSubscribe

public final void onSubscribe(org.reactivestreams.Subscription s)

Description copied from interface: FlowableSubscriber

Implementors of this method should make sure everything that needs to be visible in Subscriber.onNext(Object) is established before calling Subscription.request(long). In practice this means no initialization should happen after the request() call and additional behavior is thread safe in respect to onNext.

Specified by:

onSubscribe in interface FlowableSubscriber<T>

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<T>

createFirstWindow

abstract void createFirstWindow()

onNext

public final void onNext(T t)

Specified by:

onNext in interface org.reactivestreams.Subscriber<T>

onError

public final void onError(Throwable t)

Specified by:

onError in interface org.reactivestreams.Subscriber<T>

onComplete

public final void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<T>

request

public final void request(long n)

Specified by:

request in interface org.reactivestreams.Subscription

cancel

public final void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription

windowDone

final void windowDone()

cleanupResources

abstract void cleanupResources()

drain

abstract void drain()