Package io.reactivex.rxjava3.processors

Class MulticastProcessor.MulticastSubscription<T>

java.lang.Object

java.lang.Number

java.util.concurrent.atomic.AtomicLong

io.reactivex.rxjava3.processors.MulticastProcessor.MulticastSubscription<T>

All Implemented Interfaces:

java.io.Serializable, org.reactivestreams.Subscription

Enclosing class:

MulticastProcessor<T>

static final class MulticastProcessor.MulticastSubscription<@NonNull T>
extends java.util.concurrent.atomic.AtomicLong
implements org.reactivestreams.Subscription

Field Summary

Fields

Modifier and Type	Field	Description
(package private) org.reactivestreams.Subscriber<? super T>	downstream
(package private) long	emitted
(package private) MulticastProcessor<T>	parent
private static long	serialVersionUID

Constructor Summary

Constructors

Constructor	Description
MulticastSubscription(org.reactivestreams.Subscriber<? super @NonNull T> actual, MulticastProcessor<@NonNull T> parent)

Method Summary

Modifier and Type	Method	Description
void	cancel()
(package private) void	onComplete()
(package private) void	onError(java.lang.Throwable t)
(package private) void	onNext(@NonNull T t)
void	request(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 Detail

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

downstream

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

parent

final MulticastProcessor<T> parent

emitted

long emitted

Constructor Detail

MulticastSubscription

MulticastSubscription(org.reactivestreams.Subscriber<? super @NonNull T> actual,
                      MulticastProcessor<@NonNull T> parent)

Method Detail

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

onNext

void onNext(@NonNull T t)

onError

void onError(java.lang.Throwable t)

onComplete

void onComplete()