Class ObservableWindowBoundarySelector.WindowBoundaryMainObserver<T,​B,​V>

  • All Implemented Interfaces:
    Observer<T>, Disposable, java.io.Serializable, java.lang.Runnable
    Enclosing class:
    ObservableWindowBoundarySelector<T,​B,​V>

    static final class ObservableWindowBoundarySelector.WindowBoundaryMainObserver<T,​B,​V>
    extends java.util.concurrent.atomic.AtomicInteger
    implements Observer<T>, Disposable, java.lang.Runnable