Class OperatorBufferWithSize.BufferOverlap<T>

    • Field Detail

      • actual

        final Subscriber<? super java.util.List<T>> actual
      • count

        final int count
      • skip

        final int skip
      • index

        long index
      • queue

        final java.util.ArrayDeque<java.util.List<T>> queue
      • requested

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

        long produced
    • Constructor Detail

      • BufferOverlap

        public BufferOverlap​(Subscriber<? super java.util.List<T>> actual,
                             int count,
                             int skip)