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>, java.io.Serializable, java.lang.Runnable, org.reactivestreams.Subscriber<T>, org.reactivestreams.Subscription

Enclosing class:

FlowableWindowBoundarySelector<T,B,V>

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

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field	Description
(package private) int	bufferSize
(package private) Function<? super B,? extends org.reactivestreams.Publisher<V>>	closingIndicator
(package private) org.reactivestreams.Subscriber<? super Flowable<T>>	downstream
(package private) java.util.concurrent.atomic.AtomicBoolean	downstreamCancelled
(package private) long	emitted
(package private) AtomicThrowable	error
(package private) org.reactivestreams.Publisher<B>	open
(package private) boolean	openDone
(package private) SimplePlainQueue<java.lang.Object>	queue
(package private) java.util.concurrent.atomic.AtomicLong	requested
(package private) CompositeDisposable	resources
private static long	serialVersionUID
(package private) FlowableWindowBoundarySelector.WindowBoundaryMainSubscriber.WindowStartSubscriber<B>	startSubscriber
(package private) org.reactivestreams.Subscription	upstream
(package private) boolean	upstreamCanceled
(package private) boolean	upstreamDone
(package private) java.util.concurrent.atomic.AtomicLong	windowCount
(package private) java.util.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(java.lang.Throwable t)
(package private) void	drain()
void	onComplete()
void	onError(java.lang.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(java.lang.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 Detail

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 java.util.List<UnicastProcessor<T>> windows

queue

final SimplePlainQueue<java.lang.Object> queue

windowCount

final java.util.concurrent.atomic.AtomicLong windowCount

downstreamCancelled

final java.util.concurrent.atomic.AtomicBoolean downstreamCancelled

requested

final java.util.concurrent.atomic.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 Detail

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 Detail

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(java.lang.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 java.lang.Runnable

open

void open(B startValue)

openError

void openError(java.lang.Throwable t)

openComplete

void openComplete()

close

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

closeError

void closeError(java.lang.Throwable t)

drain

void drain()

terminateDownstream

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