Class ParallelRunOn.BaseRunOnSubscriber<T>

    • Method Summary

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

        run
    • Field Detail

      • prefetch

        final int prefetch
      • limit

        final int limit
      • upstream

        org.reactivestreams.Subscription upstream
      • done

        volatile boolean done
      • error

        java.lang.Throwable error
      • requested

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

        volatile boolean cancelled
      • consumed

        int consumed
    • Method Detail

      • onNext

        public final void onNext​(T t)
        Specified by:
        onNext in interface org.reactivestreams.Subscriber<T>
      • onError

        public final void onError​(java.lang.Throwable t)
        Specified by:
        onError in interface org.reactivestreams.Subscriber<T>
      • onComplete

        public final void onComplete()
        Specified by:
        onComplete in interface org.reactivestreams.Subscriber<T>
      • request

        public final void request​(long n)
        Specified by:
        request in interface org.reactivestreams.Subscription
      • cancel

        public final void cancel()
        Specified by:
        cancel in interface org.reactivestreams.Subscription
      • schedule

        final void schedule()