Class BufferedPushStreamImpl<T,​U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>

    • Field Detail

      • eventQueue

        private final U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>> eventQueue
      • semaphore

        private final java.util.concurrent.Semaphore semaphore
      • queuePolicy

        private final QueuePolicy<T,​U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> queuePolicy
      • pushbackPolicy

        private final PushbackPolicy<T,​U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> pushbackPolicy
      • softClose

        private final java.util.concurrent.atomic.AtomicBoolean softClose
        Indicates that a terminal event has been received, that we should stop collecting new events, and that we must drain the buffer before continuing
      • parallelism

        private final int parallelism