Package | Description |
---|---|
org.osgi.util.pushstream |
Push Stream Package Version 1.0.
|
Modifier and Type | Field and Description |
---|---|
protected QueuePolicy<T,U> |
AbstractBufferBuilder.bufferingPolicy |
private QueuePolicy<T,U> |
BufferedPushStreamImpl.queuePolicy |
private QueuePolicy<T,U> |
SimplePushEventSourceImpl.queuePolicy |
Modifier and Type | Method and Description |
---|---|
abstract <T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> |
QueuePolicyOption.getPolicy() |
Modifier and Type | Method and Description |
---|---|
(package private) <T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends 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>>> |
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) |
PushStreamBuilder<T,U> |
PushStreamBuilder.withQueuePolicy(QueuePolicy<T,U> queuePolicy) |
BufferBuilder<R,T,U> |
BufferBuilder.withQueuePolicy(QueuePolicy<T,U> queuePolicy)
Set the
QueuePolicy of this Builder |
PushStreamBuilder<T,U> |
PushStreamBuilderImpl.withQueuePolicy(QueuePolicy<T,U> queuePolicy) |
BufferBuilder<R,T,U> |
AbstractBufferBuilder.withQueuePolicy(QueuePolicy<T,U> queuePolicy) |
Constructor and 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) |