Uses of Interface
org.osgi.util.pushstream.QueuePolicy
-
Packages that use QueuePolicy Package Description org.osgi.util.pushstream Push Stream Package Version 1.0. -
-
Uses of QueuePolicy in org.osgi.util.pushstream
Fields in org.osgi.util.pushstream declared as QueuePolicy Modifier and Type Field Description protected QueuePolicy<T,U>
AbstractBufferBuilder. bufferingPolicy
private QueuePolicy<T,U>
BufferedPushStreamImpl. queuePolicy
private QueuePolicy<T,U>
SimplePushEventSourceImpl. queuePolicy
Methods in org.osgi.util.pushstream that return QueuePolicy Modifier and Type Method Description abstract <T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
QueuePolicy<T,U>QueuePolicyOption. getPolicy()
Methods in org.osgi.util.pushstream with parameters of type QueuePolicy Modifier and Type Method Description (package private) <T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
SimplePushEventSource<T>PushStreamProvider. createSimplePushEventSource(int parallelism, java.util.concurrent.Executor executor, U queue, QueuePolicy<T,U> queuePolicy, java.lang.Runnable onClose)
(package private) <T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
PushStream<T>PushStreamProvider. createStream(PushEventSource<T> eventSource, int parallelism, java.util.concurrent.Executor executor, java.util.concurrent.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<T,U>
PushStreamBuilder. withQueuePolicy(QueuePolicy<T,U> queuePolicy)
PushStreamBuilder<T,U>
PushStreamBuilderImpl. withQueuePolicy(QueuePolicy<T,U> queuePolicy)
Constructors in org.osgi.util.pushstream with parameters of type QueuePolicy Constructor Description BufferedPushStreamImpl(PushStreamProvider psp, PromiseFactory promiseFactory, U eventQueue, int parallelism, QueuePolicy<T,U> queuePolicy, PushbackPolicy<T,U> pushbackPolicy, java.util.function.Function<PushEventConsumer<T>,java.lang.AutoCloseable> connector)
SimplePushEventSourceImpl(PromiseFactory promiseFactory, QueuePolicy<T,U> queuePolicy, U queue, int parallelism, java.lang.Runnable onClose)
-