Uses of Class
org.osgi.util.pushstream.ThresholdPushbackPolicy
-
Uses of ThresholdPushbackPolicy in org.osgi.util.pushstream
Modifier and TypeMethodDescriptionstatic <T,
U extends BlockingQueue<PushEvent<? extends T>>>
ThresholdPushbackPolicy<T,U> ThresholdPushbackPolicy.createIncrementalThresholdPushbackPolicy
(int threshold, long increment) A simple configuration, where the increment size is used as the initial back pressure.static <T,
U extends BlockingQueue<PushEvent<? extends T>>>
ThresholdPushbackPolicy<T,U> ThresholdPushbackPolicy.createSimpleThresholdPushbackPolicy
(int threshold) A simple configuration with an initial back pressure of one and and increase increment size of one.static <T,
U extends BlockingQueue<PushEvent<? extends T>>>
ThresholdPushbackPolicy<T,U> ThresholdPushbackPolicy.createThresholdPushbackPolicy
(int threshold, long initial, long increment) Provides aThresholdPushbackPolicy
with an individual configuration for all possible parameters.