Class OperatorTakeLast.TakeLastSubscriber<T>

    • Field Detail

      • requested

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

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

        final int count
    • Constructor Detail

      • TakeLastSubscriber

        public TakeLastSubscriber​(Subscriber<? super T> actual,
                                  int count)