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

Class FlowableGroupBy.GroupBySubscriber<T,K,V>

java.lang.Object

java.lang.Number

java.util.concurrent.atomic.AtomicLong

io.reactivex.rxjava3.internal.operators.flowable.FlowableGroupBy.GroupBySubscriber<T,K,V>

All Implemented Interfaces:

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

Enclosing class:

FlowableGroupBy<T,K,V>

public static final class FlowableGroupBy.GroupBySubscriber<T,K,V>
extends AtomicLong
implements FlowableSubscriber<T>, org.reactivestreams.Subscription

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final int	bufferSize
(package private) final AtomicBoolean	cancelled
(package private) final boolean	delayError
(package private) boolean	done
(package private) final org.reactivestreams.Subscriber<? super GroupedFlowable<K,V>>	downstream
(package private) long	emittedGroups
(package private) final Queue<FlowableGroupBy.GroupedUnicast<K,V>>	evictedGroups
(package private) final AtomicLong	groupConsumed
(package private) final AtomicInteger	groupCount
(package private) final Map<Object,FlowableGroupBy.GroupedUnicast<K,V>>	groups
(package private) final Function<? super T,? extends K>	keySelector
(package private) final int	limit
(package private) static final Object	NULL_KEY
private static final long	serialVersionUID
(package private) org.reactivestreams.Subscription	upstream
(package private) final Function<? super T,? extends V>	valueSelector

Constructor Summary

Constructors

Constructor	Description
GroupBySubscriber(org.reactivestreams.Subscriber<? super GroupedFlowable<K,V>> actual, Function<? super T,? extends K> keySelector, Function<? super T,? extends V> valueSelector, int bufferSize, boolean delayError, Map<Object,FlowableGroupBy.GroupedUnicast<K,V>> groups, Queue<FlowableGroupBy.GroupedUnicast<K,V>> evictedGroups)

Method Summary

Modifier and Type	Method	Description
void	cancel()
void	cancel(K key)
private void	completeEvictions()
(package private) static MissingBackpressureException	groupHangWarning(long n)
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).
void	request(long n)
(package private) void	requestGroup(long n)

Methods inherited from class java.util.concurrent.atomic.AtomicLong

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 GroupedFlowable<K,V>> downstream

keySelector

final Function<? super T,? extends K> keySelector

valueSelector

final Function<? super T,? extends V> valueSelector

bufferSize

final int bufferSize

limit

final int limit

delayError

final boolean delayError

groups

final Map<Object,FlowableGroupBy.GroupedUnicast<K,V>> groups

evictedGroups

final Queue<FlowableGroupBy.GroupedUnicast<K,V>> evictedGroups

NULL_KEY

static final Object NULL_KEY

upstream

org.reactivestreams.Subscription upstream

cancelled

final AtomicBoolean cancelled

emittedGroups

long emittedGroups

groupCount

final AtomicInteger groupCount

groupConsumed

final AtomicLong groupConsumed

done

boolean done

Constructor Details

GroupBySubscriber

public GroupBySubscriber(org.reactivestreams.Subscriber<? super GroupedFlowable<K,V>> actual,
 Function<? super T,? extends K> keySelector,
 Function<? super T,? extends V> valueSelector,
 int bufferSize,
 boolean delayError,
 Map<Object,FlowableGroupBy.GroupedUnicast<K,V>> groups,
 Queue<FlowableGroupBy.GroupedUnicast<K,V>> evictedGroups)

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>

groupHangWarning

static MissingBackpressureException groupHangWarning(long n)

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

completeEvictions

private void completeEvictions()

cancel

public void cancel(K key)

requestGroup

void requestGroup(long n)