Uses of Interface
org.osgi.util.pushstream.PushbackPolicy
Packages that use PushbackPolicy
-
Uses of PushbackPolicy in org.osgi.util.pushstream
Fields in org.osgi.util.pushstream declared as PushbackPolicyModifier and TypeFieldDescriptionprotected PushbackPolicy
<T, U> AbstractBufferBuilder.backPressure
private final PushbackPolicy
<T, U> BufferedPushStreamImpl.pushbackPolicy
Methods in org.osgi.util.pushstream that return PushbackPolicyModifier and TypeMethodDescriptionabstract <T,
U extends BlockingQueue<PushEvent<? extends T>>>
PushbackPolicy<T, U> PushbackPolicyOption.getPolicy
(long value) Create aPushbackPolicy
instance configured with a base back pressure time in nanoseconds The actual backpressure returned will vary based on the selected implementation, the base value, and the state of the buffer.Methods in org.osgi.util.pushstream with parameters of type PushbackPolicyModifier and TypeMethodDescription(package private) <T,
U extends BlockingQueue<PushEvent<? extends T>>>
PushStream<T> PushStreamProvider.createStream
(PushEventSource<T> eventSource, int parallelism, Executor executor, ScheduledExecutorService scheduler, U queue, QueuePolicy<T, U> queuePolicy, PushbackPolicy<T, U> pushbackPolicy) BufferBuilder
<R, T, U> AbstractBufferBuilder.withPushbackPolicy
(PushbackPolicy<T, U> pushbackPolicy) BufferBuilder
<R, T, U> BufferBuilder.withPushbackPolicy
(PushbackPolicy<T, U> pushbackPolicy) Set thePushbackPolicy
of this builderPushStreamBuilder.withPushbackPolicy
(PushbackPolicy<T, U> pushbackPolicy) PushStreamBuilderImpl.withPushbackPolicy
(PushbackPolicy<T, U> pushbackPolicy) Constructors in org.osgi.util.pushstream with parameters of type PushbackPolicyModifierConstructorDescription(package private)
BufferedPushStreamImpl
(PushStreamProvider psp, PromiseFactory promiseFactory, U eventQueue, int parallelism, QueuePolicy<T, U> queuePolicy, PushbackPolicy<T, U> pushbackPolicy, Function<PushEventConsumer<T>, AutoCloseable> connector)