Class ObservableBufferBoundary.BufferBoundaryObserver<T,​C extends java.util.Collection<? super T>,​Open,​Close>

  • All Implemented Interfaces:
    Observer<T>, Disposable, java.io.Serializable
    Enclosing class:
    ObservableBufferBoundary<T,​U extends java.util.Collection<? super T>,​Open,​Close>

    static final class ObservableBufferBoundary.BufferBoundaryObserver<T,​C extends java.util.Collection<? super T>,​Open,​Close>
    extends java.util.concurrent.atomic.AtomicInteger
    implements Observer<T>, Disposable