Class ObservableBuffer.BufferExactObserver<T,​U extends java.util.Collection<? super T>>

  • All Implemented Interfaces:
    Observer<T>, Disposable
    Enclosing class:
    ObservableBuffer<T,​U extends java.util.Collection<? super T>>

    static final class ObservableBuffer.BufferExactObserver<T,​U extends java.util.Collection<? super T>>
    extends java.lang.Object
    implements Observer<T>, Disposable
    • Field Detail

      • downstream

        final Observer<? super U extends java.util.Collection<? super T>> downstream
      • count

        final int count
      • bufferSupplier

        final Supplier<U extends java.util.Collection<? super T>> bufferSupplier
      • buffer

        U extends java.util.Collection<? super T> buffer
      • size

        int size
    • Constructor Detail

      • BufferExactObserver

        BufferExactObserver​(Observer<? super U> actual,
                            int count,
                            Supplier<U> bufferSupplier)