Class Prefetcher


  • class Prefetcher
    extends java.lang.Object
    Simple class for encapsulating prefetch logic used across subscribers.
    • Field Detail

      • prefetch

        private final int prefetch
      • prefetchThreshold

        private final int prefetchThreshold
      • upstreamWindow

        private volatile int upstreamWindow
    • Constructor Detail

      • Prefetcher

        public Prefetcher()
    • Method Detail

      • initialize

        public void initialize​(Upstream upstream)
      • update

        public void update​(Upstream upstream)
      • currentWindow

        int currentWindow()