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 final QueuePolicy<T,U>	BufferedPushStreamImpl.queuePolicy
private final QueuePolicy<T,U>	SimplePushEventSourceImpl.queuePolicy

Methods in org.osgi.util.pushstream that return QueuePolicy

Modifier and Type	Method	Description
abstract <T, U extends 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 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 the QueuePolicy of this Builder
PushStreamBuilder<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

Modifier	Constructor	Description
(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)