Class ParallelJoin.JoinSubscriptionBase<T>

    • Constructor Summary

      Constructors 
      Constructor Description
      JoinSubscriptionBase​(org.reactivestreams.Subscriber<? super T> actual, int n, int prefetch)  
    • Method Summary

      All Methods Instance Methods Abstract Methods Concrete Methods 
      Modifier and Type Method Description
      void cancel()  
      (package private) void cancelAll()  
      (package private) void cleanup()  
      (package private) abstract void drain()  
      (package private) abstract void onComplete()  
      (package private) abstract void onError​(java.lang.Throwable e)  
      (package private) abstract void onNext​(ParallelJoin.JoinInnerSubscriber<T> inner, T value)  
      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
      • cancelled

        volatile boolean cancelled
      • done

        final java.util.concurrent.atomic.AtomicInteger done
    • Constructor Detail

      • JoinSubscriptionBase

        JoinSubscriptionBase​(org.reactivestreams.Subscriber<? super T> actual,
                             int n,
                             int prefetch)
    • 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
      • cancelAll

        void cancelAll()
      • cleanup

        void cleanup()
      • onError

        abstract void onError​(java.lang.Throwable e)
      • onComplete

        abstract void onComplete()
      • drain

        abstract void drain()