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

Class FlowableWindowBoundarySelector.WindowBoundaryMainSubscriber<T,B,V>

java.lang.Object

java.lang.Number

java.util.concurrent.atomic.AtomicInteger

io.reactivex.rxjava3.internal.operators.flowable.FlowableWindowBoundarySelector.WindowBoundaryMainSubscriber<T,B,V>

All Implemented Interfaces:

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

Enclosing class:

FlowableWindowBoundarySelector<T,B,V>

static final class FlowableWindowBoundarySelector.WindowBoundaryMainSubscriber<T,B,V>
extends AtomicInteger
implements FlowableSubscriber<T>, org.reactivestreams.Subscription, Runnable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	FlowableWindowBoundarySelector.WindowBoundaryMainSubscriber.WindowEndSubscriberIntercept<T,V>
(package private) static final class	FlowableWindowBoundarySelector.WindowBoundaryMainSubscriber.WindowStartItem<B>
(package private) static final class	FlowableWindowBoundarySelector.WindowBoundaryMainSubscriber.WindowStartSubscriber<B>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final int	bufferSize
(package private) final Function<? super B,? extends org.reactivestreams.Publisher<V>>	closingIndicator
(package private) final org.reactivestreams.Subscriber<? super Flowable<T>>	downstream
(package private) final AtomicBoolean	downstreamCancelled
(package private) long	emitted
(package private) final AtomicThrowable	error
(package private) final org.reactivestreams.Publisher<B>	open
(package private) boolean	openDone
(package private) final SimplePlainQueue<Object>	queue
(package private) final AtomicLong	requested
(package private) final CompositeDisposable	resources
private static final long	serialVersionUID
(package private) final FlowableWindowBoundarySelector.WindowBoundaryMainSubscriber.WindowStartSubscriber<B>	startSubscriber
(package private) org.reactivestreams.Subscription	upstream
(package private) boolean	upstreamCanceled
(package private) boolean	upstreamDone
(package private) final AtomicLong	windowCount
(package private) final List<UnicastProcessor<T>>	windows

Constructor Summary

Constructors

Constructor	Description
WindowBoundaryMainSubscriber(org.reactivestreams.Subscriber<? super Flowable<T>> actual, org.reactivestreams.Publisher<B> open, Function<? super B,? extends org.reactivestreams.Publisher<V>> closingIndicator, int bufferSize)

Method Summary

Modifier and Type	Method	Description
void	cancel()
(package private) void	close(FlowableWindowBoundarySelector.WindowBoundaryMainSubscriber.WindowEndSubscriberIntercept<T,V> what)
(package private) void	closeError(Throwable t)
(package private) void	drain()
void	onComplete()
void	onError(Throwable t)
void	onNext(T t)
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).
(package private) void	open(B startValue)
(package private) void	openComplete()
(package private) void	openError(Throwable t)
void	request(long n)
void	run()
(package private) void	terminateDownstream(org.reactivestreams.Subscriber<?> downstream)

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

open

final org.reactivestreams.Publisher<B> open

closingIndicator

final Function<? super B,? extends org.reactivestreams.Publisher<V>> closingIndicator

bufferSize

final int bufferSize

resources

final CompositeDisposable resources

startSubscriber

final FlowableWindowBoundarySelector.WindowBoundaryMainSubscriber.WindowStartSubscriber<B> startSubscriber

windows

final List<UnicastProcessor<T>> windows

queue

final SimplePlainQueue<Object> queue

windowCount

final AtomicLong windowCount

downstreamCancelled

final AtomicBoolean downstreamCancelled

requested

final AtomicLong requested

emitted

long emitted

upstreamCanceled

volatile boolean upstreamCanceled

upstreamDone

volatile boolean upstreamDone

openDone

volatile boolean openDone

error

final AtomicThrowable error

upstream

org.reactivestreams.Subscription upstream

Constructor Details

WindowBoundaryMainSubscriber

WindowBoundaryMainSubscriber(org.reactivestreams.Subscriber<? super Flowable<T>> actual,
 org.reactivestreams.Publisher<B> open,
 Function<? super B,? extends org.reactivestreams.Publisher<V>> closingIndicator,
 int bufferSize)

Method Details

onSubscribe

public 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>

onNext

public void onNext(T t)

Specified by:

onNext in interface org.reactivestreams.Subscriber<T>

onError

public void onError(Throwable t)

Specified by:

onError in interface org.reactivestreams.Subscriber<T>

onComplete

public void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<T>

request

public void request(long n)

Specified by:

request in interface org.reactivestreams.Subscription

cancel

public void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription

run

public void run()

Specified by:

run in interface Runnable

open

void open(B startValue)

openError

void openError(Throwable t)

openComplete

void openComplete()

close

void close(FlowableWindowBoundarySelector.WindowBoundaryMainSubscriber.WindowEndSubscriberIntercept<T,V> what)

closeError

void closeError(Throwable t)

drain

void drain()

terminateDownstream

void terminateDownstream(org.reactivestreams.Subscriber<?> downstream)