Class BlockingOperatorNext.NextObserver<T>

    • Field Detail

      • buf

        private final java.util.concurrent.BlockingQueue<Notification<? extends T>> buf
      • waiting

        final java.util.concurrent.atomic.AtomicInteger waiting
    • Constructor Detail

      • NextObserver

        NextObserver()