Class ObservableBufferTimed.BufferExactUnboundedObserver<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
      • buffer

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

        final java.util.concurrent.atomic.AtomicReference<Disposable> timer
    • Constructor Detail

      • BufferExactUnboundedObserver

        BufferExactUnboundedObserver​(Observer<? super U> actual,
                                     Supplier<U> bufferSupplier,
                                     long timespan,
                                     java.util.concurrent.TimeUnit unit,
                                     Scheduler scheduler)