Class CompletableOnSubscribeMerge.CompletableMergeSubscriber

    • Field Detail

      • maxConcurrency

        final int maxConcurrency
      • delayErrors

        final boolean delayErrors
      • done

        volatile boolean done
      • errors

        final java.util.concurrent.atomic.AtomicReference<java.util.Queue<java.lang.Throwable>> errors
      • once

        final java.util.concurrent.atomic.AtomicBoolean once
      • wip

        final java.util.concurrent.atomic.AtomicInteger wip