Class FlowableSampleTimed.SampleTimedEmitLast<T>

    • Field Detail

      • wip

        final java.util.concurrent.atomic.AtomicInteger wip
    • Constructor Detail

      • SampleTimedEmitLast

        SampleTimedEmitLast​(org.reactivestreams.Subscriber<? super T> actual,
                            long period,
                            java.util.concurrent.TimeUnit unit,
                            Scheduler scheduler,
                            Consumer<? super T> onDropped)