Class MulticastProcessor.MulticastSubscription<T>

  • All Implemented Interfaces:
    java.io.Serializable, org.reactivestreams.Subscription
    Enclosing class:
    MulticastProcessor<T>

    static final class MulticastProcessor.MulticastSubscription<@NonNull T>
    extends java.util.concurrent.atomic.AtomicLong
    implements org.reactivestreams.Subscription
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void cancel()  
      (package private) void onComplete()  
      (package private) void onError​(java.lang.Throwable t)  
      (package private) void onNext​(@NonNull T t)  
      void request​(long n)  
      • 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
      • emitted

        long emitted
    • 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
      • onError

        void onError​(java.lang.Throwable t)
      • onComplete

        void onComplete()