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