T- The type of the data
U- The type of the queue
@ConsumerType @FunctionalInterface public interface QueuePolicy<T,U extends BlockingQueue<PushEvent<? extends T>>>
QueuePolicyis used to control how events should be queued in the current buffer. The
QueuePolicywill be called when an event has arrived.
Copyright © Contributors to the Eclipse Foundation Licensed under the Eclipse Foundation Specification License – v1.0