Class ObservableTakeLastTimed.TakeLastTimedObserver<T>

    • Constructor Summary

      Constructors 
      Constructor Description
      TakeLastTimedObserver​(Observer<? super T> actual, long count, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler, int bufferSize, boolean delayError)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void dispose()
      Dispose the resource, the operation should be idempotent.
      (package private) void drain()  
      boolean isDisposed()
      Returns true if this resource has been disposed.
      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.
      • Methods inherited from class java.util.concurrent.atomic.AtomicBoolean

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

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    • Field Detail

      • downstream

        final Observer<? super T> downstream
      • count

        final long count
      • time

        final long time
      • unit

        final java.util.concurrent.TimeUnit unit
      • delayError

        final boolean delayError
      • cancelled

        volatile boolean cancelled
      • error

        java.lang.Throwable error
    • Constructor Detail

      • TakeLastTimedObserver

        TakeLastTimedObserver​(Observer<? super T> actual,
                              long count,
                              long time,
                              java.util.concurrent.TimeUnit unit,
                              Scheduler scheduler,
                              int bufferSize,
                              boolean delayError)