Class BehaviorProcessor.BehaviorSubscription<T>

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void cancel()  
      (package private) void emitFirst()  
      (package private) void emitLoop()  
      (package private) void emitNext​(java.lang.Object value, long stateIndex)  
      boolean isFull()  
      void request​(long n)  
      boolean test​(java.lang.Object o)
      Test the given input value and return a boolean.
      • Methods inherited from class java.util.concurrent.atomic.AtomicLong

        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
      • next

        boolean next
      • emitting

        boolean emitting
      • fastPath

        boolean fastPath
      • cancelled

        volatile boolean cancelled
      • index

        long index
    • 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
      • emitFirst

        void emitFirst()
      • emitNext

        void emitNext​(java.lang.Object value,
                      long stateIndex)
      • emitLoop

        void emitLoop()
      • isFull

        public boolean isFull()