Class ObservableWindowTimed.AbstractWindowObserver<T>

    • Method Summary

      All Methods Instance Methods Abstract Methods Concrete Methods 
      Modifier and Type Method Description
      (package private) abstract void cleanupResources()  
      (package private) abstract void createFirstWindow()  
      void dispose()
      Dispose the resource, the operation should be idempotent.
      (package private) abstract 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.
      (package private) void windowDone()  
      • Methods inherited from class java.util.concurrent.atomic.AtomicInteger

        accumulateAndGet, addAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, decrementAndGet, doubleValue, floatValue, get, getAcquire, getAndAccumulate, getAndAdd, getAndDecrement, getAndIncrement, getAndSet, getAndUpdate, getOpaque, getPlain, incrementAndGet, intValue, lazySet, longValue, set, setOpaque, setPlain, setRelease, toString, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile
      • Methods inherited from class java.lang.Number

        byteValue, shortValue
      • Methods inherited from class java.lang.Object

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

      • timespan

        final long timespan
      • unit

        final java.util.concurrent.TimeUnit unit
      • bufferSize

        final int bufferSize
      • emitted

        long emitted
      • done

        volatile boolean done
      • error

        java.lang.Throwable error
      • downstreamCancelled

        final java.util.concurrent.atomic.AtomicBoolean downstreamCancelled
      • upstreamCancelled

        volatile boolean upstreamCancelled
      • windowCount

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

      • AbstractWindowObserver

        AbstractWindowObserver​(Observer<? super Observable<T>> downstream,
                               long timespan,
                               java.util.concurrent.TimeUnit unit,
                               int bufferSize)
    • Method Detail

      • createFirstWindow

        abstract void createFirstWindow()
      • onError

        public final void onError​(java.lang.Throwable t)
        Description copied from interface: Observer
        Notifies the Observer that the Observable has experienced an error condition.

        If the Observable calls this method, it will not thereafter call Observer.onNext(T) or Observer.onComplete().

        Specified by:
        onError in interface Observer<T>
        Parameters:
        t - the exception encountered by the Observable
      • dispose

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

        public final 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
      • windowDone

        final void windowDone()
      • cleanupResources

        abstract void cleanupResources()
      • drain

        abstract void drain()