Package | Description |
---|---|
org.osgi.util.pushstream |
Push Stream Package Version 1.0.
|
Modifier and Type | Interface and Description |
---|---|
interface |
PushStreamBuilder<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
A Builder for a PushStream.
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
AbstractBufferBuilder<R,T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> |
(package private) class |
PushStreamBuilderImpl<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> |
Modifier and Type | Method and Description |
---|---|
<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> |
PushStreamProvider.buildBufferedConsumer(PushEventConsumer<T> delegate)
Build a buffered
PushEventConsumer with custom configuration. |
<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> |
PushStreamProvider.buildEventSourceFromStream(PushStream<T> stream)
Convert an
PushStream into an PushEventSource . |
<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> |
PushStreamProvider.buildSimpleEventSource(java.lang.Class<T> type)
Build a
SimplePushEventSource with the supplied type and custom
buffering behaviors. |
BufferBuilder<R,T,U> |
BufferBuilder.withBuffer(U queue)
The BlockingQueue implementation to use as a buffer
|
BufferBuilder<R,T,U> |
AbstractBufferBuilder.withBuffer(U queue) |
BufferBuilder<R,T,U> |
BufferBuilder.withExecutor(java.util.concurrent.Executor executor)
Set the
Executor that should be used to deliver events from this
buffer |
BufferBuilder<R,T,U> |
AbstractBufferBuilder.withExecutor(java.util.concurrent.Executor executor) |
BufferBuilder<R,T,U> |
BufferBuilder.withParallelism(int parallelism)
Set the maximum permitted number of concurrent event deliveries allowed
from this buffer
|
BufferBuilder<R,T,U> |
AbstractBufferBuilder.withParallelism(int parallelism) |
BufferBuilder<R,T,U> |
BufferBuilder.withPushbackPolicy(PushbackPolicy<T,U> pushbackPolicy)
Set the
PushbackPolicy of this builder |
BufferBuilder<R,T,U> |
AbstractBufferBuilder.withPushbackPolicy(PushbackPolicy<T,U> pushbackPolicy) |
BufferBuilder<R,T,U> |
BufferBuilder.withPushbackPolicy(PushbackPolicyOption pushbackPolicyOption,
long time)
Set the
PushbackPolicy of this builder |
BufferBuilder<R,T,U> |
AbstractBufferBuilder.withPushbackPolicy(PushbackPolicyOption pushbackPolicyOption,
long time) |
BufferBuilder<R,T,U> |
BufferBuilder.withQueuePolicy(QueuePolicy<T,U> queuePolicy)
Set the
QueuePolicy of this Builder |
BufferBuilder<R,T,U> |
AbstractBufferBuilder.withQueuePolicy(QueuePolicy<T,U> queuePolicy) |
BufferBuilder<R,T,U> |
BufferBuilder.withQueuePolicy(QueuePolicyOption queuePolicyOption)
Set the
QueuePolicy of this Builder |
BufferBuilder<R,T,U> |
AbstractBufferBuilder.withQueuePolicy(QueuePolicyOption queuePolicyOption) |
BufferBuilder<R,T,U> |
BufferBuilder.withScheduler(java.util.concurrent.ScheduledExecutorService scheduler)
Set the
ScheduledExecutorService that should be used to trigger
timed events after this buffer |
BufferBuilder<R,T,U> |
AbstractBufferBuilder.withScheduler(java.util.concurrent.ScheduledExecutorService scheduler) |