T- The type of the data
U- The type of the queue
@ConsumerType @FunctionalInterface public interface PushbackPolicy<T,U extends BlockingQueue<PushEvent<? extends T>>>
PushbackPolicyis used to calculate how much back pressure to apply based on the current buffer. The
PushbackPolicywill be called after an event has been queued, and the returned value will be used as back pressure.
Copyright © Contributors to the Eclipse Foundation Licensed under the Eclipse Foundation Specification License – v1.0