Class FlowableZip.ZipCoordinator<T,R>

java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicInteger
io.reactivex.rxjava3.internal.operators.flowable.FlowableZip.ZipCoordinator<T,R>
All Implemented Interfaces:
Serializable, org.reactivestreams.Subscription
Enclosing class:
FlowableZip<T,R>

static final class FlowableZip.ZipCoordinator<T,R> extends AtomicInteger implements org.reactivestreams.Subscription
  • Field Details

    • serialVersionUID

      private static final long serialVersionUID
      See Also:
    • downstream

      final org.reactivestreams.Subscriber<? super R> downstream
    • subscribers

      final FlowableZip.ZipSubscriber<T,R>[] subscribers
    • zipper

      final Function<? super Object[],? extends R> zipper
    • requested

      final AtomicLong requested
    • errors

      final AtomicThrowable errors
    • delayErrors

      final boolean delayErrors
    • cancelled

      volatile boolean cancelled
    • current

      final Object[] current
  • Constructor Details

    • ZipCoordinator

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

    • 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
    • error

      void error(FlowableZip.ZipSubscriber<T,R> inner, Throwable e)
    • cancelAll

      void cancelAll()
    • drain

      void drain()