Uses of Interface
org.osgi.util.pushstream.QueuePolicy
Packages that use QueuePolicy
-
Uses of QueuePolicy in org.osgi.util.pushstream
Fields in org.osgi.util.pushstream declared as QueuePolicyModifier and TypeFieldDescriptionprotected QueuePolicy<T,
U> AbstractBufferBuilder.bufferingPolicy
private final QueuePolicy<T,
U> BufferedPushStreamImpl.queuePolicy
private final QueuePolicy<T,
U> SimplePushEventSourceImpl.queuePolicy
Methods in org.osgi.util.pushstream that return QueuePolicyModifier and TypeMethodDescriptionabstract <T,
U extends BlockingQueue<PushEvent<? extends T>>>
QueuePolicy<T,U> QueuePolicyOption.getPolicy()
Methods in org.osgi.util.pushstream with parameters of type QueuePolicyModifier and TypeMethodDescription(package private) <T,
U extends BlockingQueue<PushEvent<? extends T>>>
SimplePushEventSource<T>PushStreamProvider.createSimplePushEventSource
(int parallelism, Executor executor, U queue, QueuePolicy<T, U> queuePolicy, Runnable onClose) (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.withQueuePolicy
(QueuePolicy<T, U> queuePolicy) BufferBuilder<R,
T, U> BufferBuilder.withQueuePolicy
(QueuePolicy<T, U> queuePolicy) Set theQueuePolicy
of this BuilderPushStreamBuilder.withQueuePolicy
(QueuePolicy<T, U> queuePolicy) PushStreamBuilderImpl.withQueuePolicy
(QueuePolicy<T, U> queuePolicy) Constructors in org.osgi.util.pushstream with parameters of type QueuePolicyModifierConstructorDescription(package private)
BufferedPushStreamImpl
(PushStreamProvider psp, PromiseFactory promiseFactory, U eventQueue, int parallelism, QueuePolicy<T, U> queuePolicy, PushbackPolicy<T, U> pushbackPolicy, Function<PushEventConsumer<T>, AutoCloseable> connector) SimplePushEventSourceImpl
(PromiseFactory promiseFactory, QueuePolicy<T, U> queuePolicy, U queue, int parallelism, Runnable onClose)