Class ObservableBufferTimed.BufferExactBoundedObserver<T,​U extends java.util.Collection<? super T>>

    • Field Detail

      • bufferSupplier

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

        final long timespan
      • unit

        final java.util.concurrent.TimeUnit unit
      • maxSize

        final int maxSize
      • restartTimerOnMaxSize

        final boolean restartTimerOnMaxSize
      • buffer

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

        long producerIndex
      • consumerIndex

        long consumerIndex
    • Constructor Detail

      • BufferExactBoundedObserver

        BufferExactBoundedObserver​(Observer<? super U> actual,
                                   Supplier<U> bufferSupplier,
                                   long timespan,
                                   java.util.concurrent.TimeUnit unit,
                                   int maxSize,
                                   boolean restartOnMaxSize,
                                   Scheduler.Worker w)