Package io.servicetalk.concurrent.api
Interface GroupedPublisher.QueueSizeProvider
-
- Enclosing class:
- GroupedPublisher<Key,T>
public static interface GroupedPublisher.QueueSizeProvider
Provide the maximum queue size to use for a particularGroupedPublisher
key.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description int
calculateMaxQueueSize(int groupMaxQueueSize)
Calculate the maximum queue size for a particularGroupedPublisher
key.
-
-
-
Method Detail
-
calculateMaxQueueSize
int calculateMaxQueueSize(int groupMaxQueueSize)
Calculate the maximum queue size for a particularGroupedPublisher
key.- Parameters:
groupMaxQueueSize
- The maximum queue size forGroupedPublisher
objects.- Returns:
- The maximum queue size for a particular
GroupedPublisher
key.
-
-