Class ParallelRunOn.RunOnSubscriber<T>
- java.lang.Object
-
- java.lang.Number
-
- java.util.concurrent.atomic.AtomicInteger
-
- io.reactivex.rxjava3.internal.operators.parallel.ParallelRunOn.BaseRunOnSubscriber<T>
-
- io.reactivex.rxjava3.internal.operators.parallel.ParallelRunOn.RunOnSubscriber<T>
-
- All Implemented Interfaces:
FlowableSubscriber<T>
,java.io.Serializable
,java.lang.Runnable
,org.reactivestreams.Subscriber<T>
,org.reactivestreams.Subscription
- Enclosing class:
- ParallelRunOn<T>
static final class ParallelRunOn.RunOnSubscriber<T> extends ParallelRunOn.BaseRunOnSubscriber<T>
-
-
Field Summary
Fields Modifier and Type Field Description (package private) org.reactivestreams.Subscriber<? super T>
downstream
private static long
serialVersionUID
-
Constructor Summary
Constructors Constructor Description RunOnSubscriber(org.reactivestreams.Subscriber<? super T> actual, int prefetch, SpscArrayQueue<T> queue, Scheduler.Worker worker)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onSubscribe(org.reactivestreams.Subscription s)
Implementors of this method should make sure everything that needs to be visible inSubscriber.onNext(Object)
is established before callingSubscription.request(long)
.void
run()
-
Methods inherited from class io.reactivex.rxjava3.internal.operators.parallel.ParallelRunOn.BaseRunOnSubscriber
cancel, onComplete, onError, onNext, request, schedule
-
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
-
-
-
-
Field Detail
-
serialVersionUID
private static final long serialVersionUID
- See Also:
- Constant Field Values
-
downstream
final org.reactivestreams.Subscriber<? super T> downstream
-
-
Constructor Detail
-
RunOnSubscriber
RunOnSubscriber(org.reactivestreams.Subscriber<? super T> actual, int prefetch, SpscArrayQueue<T> queue, Scheduler.Worker worker)
-
-
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 inSubscriber.onNext(Object)
is established before callingSubscription.request(long)
. In practice this means no initialization should happen after therequest()
call and additional behavior is thread safe in respect toonNext
.
-
run
public void run()
-
-