Package io.reactivex.rxjava3.internal.observers

Class DeferredScalarDisposable<T>

    • Field Summary

      Fields 
      Modifier and Type Field Description
      (package private) static int DISPOSED
      Indicates the Disposable has been disposed.
      protected Observer<? super T> downstream
      The target of the events.
      (package private) static int FUSED_CONSUMED
      Indicates this Disposable is in fusion mode and its value has been consumed.
      (package private) static int FUSED_EMPTY
      Indicates this Disposable is in fusion mode and is currently empty.
      (package private) static int FUSED_READY
      Indicates this Disposable is in fusion mode and has a value.
      private static long serialVersionUID  
      (package private) static int TERMINATED
      Indicates there was a call to complete(T).
      protected T value
      The value stored temporarily when in fusion mode.

    • Constructor Summary

      Constructors 
      Constructor Description
      DeferredScalarDisposable​(Observer<? super T> downstream)
      Constructs a DeferredScalarDisposable by wrapping the Observer.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void clear()
      Removes all enqueued items from this queue.
      void complete()
      Complete the target without any value.
      void complete​(T value)
      Complete the target with a single value or indicate there is a value available in fusion mode.
      void dispose()
      Dispose the resource, the operation should be idempotent.
      void error​(java.lang.Throwable t)
      Complete the target with an error signal.
      boolean isDisposed()
      Returns true if this resource has been disposed.
      boolean isEmpty()
      Returns true if the queue is empty.
      T poll()
      Tries to dequeue a value (non-null) or returns null if the queue is empty.
      int requestFusion​(int mode)
      Request a fusion mode from the upstream.
      boolean tryDispose()
      Try disposing this Disposable and return true if the current thread succeeded.

      • 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

      • downstream

        protected final Observer<? super T> downstream
        The target of the events.

      • value

        protected T value
        The value stored temporarily when in fusion mode.

      • TERMINATED

        static final int TERMINATED
        Indicates there was a call to complete(T).
        See Also:
        Constant Field Values

      • DISPOSED

        static final int DISPOSED
        Indicates the Disposable has been disposed.
        See Also:
        Constant Field Values

      • FUSED_EMPTY

        static final int FUSED_EMPTY
        Indicates this Disposable is in fusion mode and is currently empty.
        See Also:
        Constant Field Values

      • FUSED_READY

        static final int FUSED_READY
        Indicates this Disposable is in fusion mode and has a value.
        See Also:
        Constant Field Values

      • FUSED_CONSUMED

        static final int FUSED_CONSUMED
        Indicates this Disposable is in fusion mode and its value has been consumed.
        See Also:
        Constant Field Values

    • Constructor Detail

      • DeferredScalarDisposable

        public DeferredScalarDisposable​(Observer<? super T> downstream)
        Constructs a DeferredScalarDisposable by wrapping the Observer.
        Parameters:
        downstream - the Observer to wrap, not null (not verified)

    • Method Detail

      • complete

        public final void complete​(T value)
        Complete the target with a single value or indicate there is a value available in fusion mode.
        Parameters:
        value - the value to signal, not null (not verified)

      • error

        public final void error​(java.lang.Throwable t)
        Complete the target with an error signal.
        Parameters:
        t - the Throwable to signal, not null (not verified)

      • complete

        public final void complete()
        Complete the target without any value.

      • poll

        @Nullable
public final T poll()
        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

      • 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).

        Returns:
        true if the queue is empty

      • clear

        public final void clear()
        Description copied from interface: SimpleQueue
        Removes all enqueued items from this queue.

      • dispose

        public void dispose()
        Description copied from interface: Disposable
        Dispose the resource, the operation should be idempotent.

      • tryDispose

        public final boolean tryDispose()
        Try disposing this Disposable and return true if the current thread succeeded.
        Returns:
        true if the current thread succeeded

      • isDisposed

        public final boolean isDisposed()
        Description copied from interface: Disposable
        Returns true if this resource has been disposed.
        Returns:
        true if this resource has been disposed