T- The type of the data
U- The type of the queue
@ConsumerType @FunctionalInterface public interface PushbackPolicy<T,U extends java.util.concurrent.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.
long pushback(U queue) throws java.lang.Exception
Copyright © OSGi Alliance (2000, 2018). All Rights Reserved. Licensed under the OSGi Specification License, Version 2.0