Class BlockingObservableIterable.BlockingObservableIterator<T>

    • Field Summary

      Fields 
      Modifier and Type Field Description
      (package private) java.util.concurrent.locks.Condition condition  
      (package private) boolean done  
      (package private) java.lang.Throwable error  
      (package private) java.util.concurrent.locks.Lock lock  
      (package private) SpscLinkedArrayQueue<T> queue  
      private static long serialVersionUID  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void dispose()
      Dispose the resource, the operation should be idempotent.
      boolean hasNext()  
      boolean isDisposed()
      Returns true if this resource has been disposed.
      T next()  
      void onComplete()
      Notifies the Observer that the Observable has finished sending push-based notifications.
      void onError​(java.lang.Throwable t)
      Notifies the Observer that the Observable has experienced an error condition.
      void onNext​(T t)
      Provides the Observer with a new item to observe.
      void onSubscribe​(Disposable d)
      Provides the Observer with the means of cancelling (disposing) the connection (channel) with the Observable in both synchronous (from within Observer.onNext(Object)) and asynchronous manner.
      void remove()  
      (package private) void signalConsumer()  
      • Methods inherited from class java.util.concurrent.atomic.AtomicReference

        accumulateAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, get, getAcquire, getAndAccumulate, getAndSet, getAndUpdate, getOpaque, getPlain, lazySet, set, setOpaque, setPlain, setRelease, toString, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
      • Methods inherited from interface java.util.Iterator

        forEachRemaining
    • Field Detail

      • lock

        final java.util.concurrent.locks.Lock lock
      • condition

        final java.util.concurrent.locks.Condition condition
      • done

        volatile boolean done
      • error

        volatile java.lang.Throwable error
    • Constructor Detail

      • BlockingObservableIterator

        BlockingObservableIterator​(int batchSize)
    • Method Detail

      • hasNext

        public boolean hasNext()
        Specified by:
        hasNext in interface java.util.Iterator<T>
      • next

        public T next()
        Specified by:
        next in interface java.util.Iterator<T>
      • signalConsumer

        void signalConsumer()
      • remove

        public void remove()
        Specified by:
        remove in interface java.util.Iterator<T>
      • dispose

        public void dispose()
        Description copied from interface: Disposable
        Dispose the resource, the operation should be idempotent.
        Specified by:
        dispose in interface Disposable
      • isDisposed

        public boolean isDisposed()
        Description copied from interface: Disposable
        Returns true if this resource has been disposed.
        Specified by:
        isDisposed in interface Disposable
        Returns:
        true if this resource has been disposed