Class FlowableObserveOn.BaseObserveOnSubscriber<T>

    • Method Summary

      All Methods Instance Methods Abstract Methods Concrete Methods 
      Modifier and Type Method Description
      void cancel()  
      (package private) boolean checkTerminated​(boolean d, boolean empty, org.reactivestreams.Subscriber<?> a)  
      void clear()
      Removes all enqueued items from this queue.
      boolean isEmpty()
      Returns true if the queue is empty.
      void onComplete()  
      void onError​(java.lang.Throwable t)  
      void onNext​(T t)  
      void request​(long n)  
      int requestFusion​(int requestedMode)
      Request a fusion mode from the upstream.
      void run()  
      (package private) abstract void runAsync()  
      (package private) abstract void runBackfused()  
      (package private) abstract void runSync()  
      (package private) void trySchedule()  
      • 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
      • Methods inherited from interface io.reactivex.rxjava3.operators.SimpleQueue

        poll
    • Field Detail

      • delayError

        final boolean delayError
      • prefetch

        final int prefetch
      • limit

        final int limit
      • requested

        final java.util.concurrent.atomic.AtomicLong requested
      • upstream

        org.reactivestreams.Subscription upstream
      • cancelled

        volatile boolean cancelled
      • done

        volatile boolean done
      • error

        java.lang.Throwable error
      • sourceMode

        int sourceMode
      • produced

        long produced
      • outputFused

        boolean outputFused
    • Constructor Detail

      • BaseObserveOnSubscriber

        BaseObserveOnSubscriber​(Scheduler.Worker worker,
                                boolean delayError,
                                int prefetch)
    • Method Detail

      • onNext

        public final void onNext​(T t)
        Specified by:
        onNext in interface org.reactivestreams.Subscriber<T>
      • onError

        public final void onError​(java.lang.Throwable t)
        Specified by:
        onError in interface org.reactivestreams.Subscriber<T>
      • onComplete

        public final void onComplete()
        Specified by:
        onComplete in interface org.reactivestreams.Subscriber<T>
      • request

        public final void request​(long n)
        Specified by:
        request in interface org.reactivestreams.Subscription
      • cancel

        public final void cancel()
        Specified by:
        cancel in interface org.reactivestreams.Subscription
      • trySchedule

        final void trySchedule()
      • run

        public final void run()
        Specified by:
        run in interface java.lang.Runnable
      • runBackfused

        abstract void runBackfused()
      • runSync

        abstract void runSync()
      • runAsync

        abstract void runAsync()
      • checkTerminated

        final boolean checkTerminated​(boolean d,
                                      boolean empty,
                                      org.reactivestreams.Subscriber<?> a)
      • clear

        public final void clear()
        Description copied from interface: SimpleQueue
        Removes all enqueued items from this queue.
        Specified by:
        clear in interface SimpleQueue<T>
      • isEmpty

        public final boolean isEmpty()
        Description copied from interface: SimpleQueue
        Returns true if the queue is empty.

        Note however that due to potential fused functions in SimpleQueue.poll() it is possible this method returns false but then poll() returns null because the fused function swallowed the available item(s).

        Specified by:
        isEmpty in interface SimpleQueue<T>
        Returns:
        true if the queue is empty