Class ObservableBufferTimed.BufferSkipBoundedObserver<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
      • timeskip

        final long timeskip
      • unit

        final java.util.concurrent.TimeUnit unit
      • buffers

        final java.util.List<U extends java.util.Collection<? super T>> buffers
    • Constructor Detail

      • BufferSkipBoundedObserver

        BufferSkipBoundedObserver​(Observer<? super U> actual,
                                  Supplier<U> bufferSupplier,
                                  long timespan,
                                  long timeskip,
                                  java.util.concurrent.TimeUnit unit,
                                  Scheduler.Worker w)