Class FlowableCache.CacheSubscription<T>

  • Type Parameters:
    T - the value type
    All Implemented Interfaces:
    java.io.Serializable, org.reactivestreams.Subscription
    Enclosing class:
    FlowableCache<T>

    static final class FlowableCache.CacheSubscription<T>
    extends java.util.concurrent.atomic.AtomicInteger
    implements org.reactivestreams.Subscription
    Hosts the downstream consumer and its current requested and replay states. this holds the work-in-progress counter for the serialized replay.
    • Constructor Summary

      Constructors 
      Constructor Description
      CacheSubscription​(org.reactivestreams.Subscriber<? super T> downstream, FlowableCache<T> parent)
      Constructs a new instance with the actual downstream consumer and the parent cache object.
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void cancel()  
      void request​(long n)  
      • 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

        final org.reactivestreams.Subscriber<? super T> downstream
      • requested

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

        int offset
      • index

        long index
    • Constructor Detail

      • CacheSubscription

        CacheSubscription​(org.reactivestreams.Subscriber<? super T> downstream,
                          FlowableCache<T> parent)
        Constructs a new instance with the actual downstream consumer and the parent cache object.
        Parameters:
        downstream - the actual consumer
        parent - the parent that holds onto the cached items
    • 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