Interface PushbackPolicy<T, U extends BlockingQueue<PushEvent<? extends T>>>

Type Parameters:
T - The type of the data
U - The type of the queue
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@ConsumerType @FunctionalInterface public interface PushbackPolicy<T, U extends BlockingQueue<PushEvent<? extends T>>>
A PushbackPolicy is used to calculate how much back pressure to apply based on the current buffer. The PushbackPolicy will be called after an event has been queued, and the returned value will be used as back pressure.
See Also:

  • Method Summary

    Modifier and Type
    Method
    Description
    long
    pushback(U queue)
    Given the current state of the queue, determine the level of back pressure that should be applied

  • Method Details

    • pushback

      long pushback(U queue) throws Exception
      Given the current state of the queue, determine the level of back pressure that should be applied
      Parameters:
      queue -
      Returns:
      a back pressure value in nanoseconds
      Throws:
      Exception