Class BlockingObservableNext.NextObserver<T>

    • Field Detail

      • buf

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

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

      • NextObserver

        NextObserver()