Class OperatorWindowWithSize.WindowOverlap<T>

    • Field Detail

      • size

        final int size
      • skip

        final int skip
      • wip

        final java.util.concurrent.atomic.AtomicInteger wip
      • windows

        final java.util.ArrayDeque<Subject<T,​T>> windows
      • requested

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

        final java.util.concurrent.atomic.AtomicInteger drainWip
      • queue

        final java.util.Queue<Subject<T,​T>> queue
      • error

        java.lang.Throwable error
      • done

        volatile boolean done
      • index

        int index
      • produced

        int produced
    • Constructor Detail

      • WindowOverlap

        public WindowOverlap​(Subscriber<? super Observable<T>> actual,
                             int size,
                             int skip)