Class ParallelSortedJoin.SortedJoinSubscription<T>

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

    static final class ParallelSortedJoin.SortedJoinSubscription<T>
    extends java.util.concurrent.atomic.AtomicInteger
    implements org.reactivestreams.Subscription
    • Constructor Summary

      Constructors 
      Constructor Description
      SortedJoinSubscription​(org.reactivestreams.Subscriber<? super T> actual, int n, java.util.Comparator<? super T> comparator)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void cancel()  
      (package private) void cancelAll()  
      (package private) void drain()  
      (package private) void innerError​(java.lang.Throwable e)  
      (package private) void innerNext​(java.util.List<T> value, int index)  
      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
      • lists

        final java.util.List<T>[] lists
      • indexes

        final int[] indexes
      • comparator

        final java.util.Comparator<? super T> comparator
      • requested

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

        volatile boolean cancelled
      • remaining

        final java.util.concurrent.atomic.AtomicInteger remaining
      • error

        final java.util.concurrent.atomic.AtomicReference<java.lang.Throwable> error
    • Constructor Detail

      • SortedJoinSubscription

        SortedJoinSubscription​(org.reactivestreams.Subscriber<? super T> actual,
                               int n,
                               java.util.Comparator<? super T> comparator)
    • 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()
      • innerNext

        void innerNext​(java.util.List<T> value,
                       int index)
      • innerError

        void innerError​(java.lang.Throwable e)
      • drain

        void drain()