Class FlowableZip.ZipCoordinator<T,​R>

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

    static final class FlowableZip.ZipCoordinator<T,​R>
    extends java.util.concurrent.atomic.AtomicInteger
    implements org.reactivestreams.Subscription
    • Constructor Summary

      Constructors 
      Constructor Description
      ZipCoordinator​(org.reactivestreams.Subscriber<? super R> actual, Function<? super java.lang.Object[],​? extends R> zipper, int n, int prefetch, boolean delayErrors)  
    • 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 error​(FlowableZip.ZipSubscriber<T,​R> inner, java.lang.Throwable e)  
      void request​(long n)  
      (package private) void subscribe​(org.reactivestreams.Publisher<? extends T>[] sources, int 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 R> downstream
      • zipper

        final Function<? super java.lang.Object[],​? extends R> zipper
      • requested

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

        final boolean delayErrors
      • cancelled

        volatile boolean cancelled
      • current

        final java.lang.Object[] current
    • Constructor Detail

      • ZipCoordinator

        ZipCoordinator​(org.reactivestreams.Subscriber<? super R> actual,
                       Function<? super java.lang.Object[],​? extends R> zipper,
                       int n,
                       int prefetch,
                       boolean delayErrors)
    • Method Detail

      • subscribe

        void subscribe​(org.reactivestreams.Publisher<? extends T>[] sources,
                       int n)
      • 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()
      • drain

        void drain()