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

Class FlowableObserveOn.ObserveOnSubscriber<T>

java.lang.Object

java.lang.Number

java.util.concurrent.atomic.AtomicInteger

io.reactivex.rxjava3.internal.subscriptions.BasicIntQueueSubscription<T>

io.reactivex.rxjava3.internal.operators.flowable.FlowableObserveOn.BaseObserveOnSubscriber<T>

io.reactivex.rxjava3.internal.operators.flowable.FlowableObserveOn.ObserveOnSubscriber<T>

All Implemented Interfaces:

FlowableSubscriber<T>, QueueFuseable<T>, QueueSubscription<T>, SimpleQueue<T>, java.io.Serializable, java.lang.Runnable, org.reactivestreams.Subscriber<T>, org.reactivestreams.Subscription

Enclosing class:

FlowableObserveOn<T>

static final class FlowableObserveOn.ObserveOnSubscriber<T>
extends FlowableObserveOn.BaseObserveOnSubscriber<T>

Field Summary

Fields

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

Fields inherited from class io.reactivex.rxjava3.internal.operators.flowable.FlowableObserveOn.BaseObserveOnSubscriber

cancelled, delayError, done, error, limit, outputFused, prefetch, produced, queue, requested, sourceMode, upstream, worker

Fields inherited from interface io.reactivex.rxjava3.operators.QueueFuseable

ANY, ASYNC, BOUNDARY, NONE, SYNC

Constructor Summary

Constructors

Constructor	Description
ObserveOnSubscriber(org.reactivestreams.Subscriber<? super T> actual, Scheduler.Worker worker, boolean delayError, int prefetch)

Method Summary

Modifier and Type	Method	Description
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).
T	poll()	Tries to dequeue a value (non-null) or returns null if the queue is empty.
(package private) void	runAsync()
(package private) void	runBackfused()
(package private) void	runSync()

Methods inherited from class io.reactivex.rxjava3.internal.operators.flowable.FlowableObserveOn.BaseObserveOnSubscriber

cancel, checkTerminated, clear, isEmpty, onComplete, onError, onNext, request, requestFusion, run, trySchedule

Methods inherited from class io.reactivex.rxjava3.internal.subscriptions.BasicIntQueueSubscription

offer, offer

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 T> downstream

Constructor Detail

ObserveOnSubscriber

ObserveOnSubscriber(org.reactivestreams.Subscriber<? super T> actual,
                    Scheduler.Worker worker,
                    boolean delayError,
                    int prefetch)

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.

runSync

void runSync()

Specified by:

runSync in class FlowableObserveOn.BaseObserveOnSubscriber<T>

runAsync

void runAsync()

Specified by:

runAsync in class FlowableObserveOn.BaseObserveOnSubscriber<T>

runBackfused

void runBackfused()

Specified by:

runBackfused in class FlowableObserveOn.BaseObserveOnSubscriber<T>

poll

@Nullable
public T poll()
       throws java.lang.Throwable

Description copied from interface: SimpleQueue

Tries to dequeue a value (non-null) or returns null if the queue is empty.

If the producer uses SimpleQueue.offer(Object, Object) and when polling in pairs, if the first poll() returns a non-null item, the second poll() is guaranteed to return a non-null item as well.

Returns:

the item or null to indicate an empty queue

Throws:

java.lang.Throwable - if some pre-processing of the dequeued item (usually through fused functions) throws.