Class OperatorTakeLastTimed.TakeLastTimedSubscriber<T>

    • Field Detail

      • ageMillis

        final long ageMillis
      • count

        final int count
      • requested

        final java.util.concurrent.atomic.AtomicLong requested
      • queue

        final java.util.ArrayDeque<java.lang.Object> queue
      • queueTimes

        final java.util.ArrayDeque<java.lang.Long> queueTimes
    • Constructor Detail

      • TakeLastTimedSubscriber

        public TakeLastTimedSubscriber​(Subscriber<? super T> actual,
                                       int count,
                                       long ageMillis,
                                       Scheduler scheduler)