?? QueuePolicy<T,U extends BlockingQueue<PushEvent<? extends T>>>

????:
T - The type of the data
U - The type of the queue
????:
????????, ????? lambda ??????????????

@ConsumerType @FunctionalInterface public interface QueuePolicy<T,U extends BlockingQueue<PushEvent<? extends T>>>
A QueuePolicy is used to control how events should be queued in the current buffer. The QueuePolicy will be called when an event has arrived.
????:
  • ????

    ??????
    ??
    ??
    void
    doOffer(U queue, PushEvent<? extends T> event)
    Enqueue the event and return the remaining capacity available for events