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

Class FlowableGroupBy.State<T,​K>

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void cancel()  
      (package private) void cancelParent()  
      (package private) boolean checkTerminated​(boolean d, boolean empty, org.reactivestreams.Subscriber<? super T> a, boolean delayError, long emitted, boolean polled)  
      (package private) void cleanupQueue​(long emitted, boolean polled)  
      void clear()
      Removes all enqueued items from this queue.
      (package private) void drain()  
      (package private) void drainFused()  
      (package private) void drainNormal()  
      boolean isEmpty()
      Returns true if the queue is empty.
      void onComplete()  
      void onError​(java.lang.Throwable e)  
      void onNext​(T t)  
      T poll()
      Tries to dequeue a value (non-null) or returns null if the queue is empty.
      (package private) void replenishParent​(long emitted, boolean polled)  
      void request​(long n)  
      int requestFusion​(int mode)
      Request a fusion mode from the upstream.
      (package private) void requestParent​(long e)  
      void subscribe​(org.reactivestreams.Subscriber<? super T> subscriber)  
      (package private) boolean tryAbandon()  
      (package private) boolean tryComplete()  
      (package private) void tryReplenish()  

      • 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

      • key

        final K key

      • delayError

        final boolean delayError

      • requested

        final java.util.concurrent.atomic.AtomicLong requested

      • done

        volatile boolean done

      • error

        java.lang.Throwable error

      • cancelled

        final java.util.concurrent.atomic.AtomicBoolean cancelled

      • actual

        final java.util.concurrent.atomic.AtomicReference<org.reactivestreams.Subscriber<? super T>> actual

      • outputFused

        boolean outputFused

      • produced

        int produced

      • once

        final java.util.concurrent.atomic.AtomicInteger once

      • evictOnce

        final java.util.concurrent.atomic.AtomicBoolean evictOnce

    • 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

      • subscribe

        public void subscribe​(org.reactivestreams.Subscriber<? super T> subscriber)
        Specified by:
        subscribe in interface org.reactivestreams.Publisher<T>

      • onNext

        public void onNext​(T t)

      • onError

        public void onError​(java.lang.Throwable e)

      • onComplete

        public void onComplete()

      • tryComplete

        boolean tryComplete()

      • cancelParent

        void cancelParent()

      • tryAbandon

        boolean tryAbandon()

      • drain

        void drain()

      • drainFused

        void drainFused()

      • drainNormal

        void drainNormal()

      • requestParent

        void requestParent​(long e)

      • cleanupQueue

        void cleanupQueue​(long emitted,
                  boolean polled)

      • replenishParent

        void replenishParent​(long emitted,
                     boolean polled)

      • checkTerminated

        boolean checkTerminated​(boolean d,
                        boolean empty,
                        org.reactivestreams.Subscriber<? super T> a,
                        boolean delayError,
                        long emitted,
                        boolean polled)

      • tryReplenish

        void tryReplenish()

      • poll

        @Nullable
public 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.

        Specified by:
        poll in interface SimpleQueue<T>
        Returns:
        the item or null to indicate an empty queue

      • isEmpty

        public 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

      • clear

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