Class BlockingFlowableNext.NextSubscriber<T>

    • Field Detail

      • buf

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

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

      • NextSubscriber

        NextSubscriber()
    • Method Detail

      • onComplete

        public void onComplete()
      • onError

        public void onError​(java.lang.Throwable e)
      • takeNext

        public Notification<T> takeNext()
                                 throws java.lang.InterruptedException
        Throws:
        java.lang.InterruptedException
      • setWaiting

        void setWaiting()