<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> BufferBuilder<PushEventConsumer<T>,T,U> |
PushStreamProvider.buildBufferedConsumer(PushEventConsumer<T> delegate) |
|
<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> BufferBuilder<PushEventSource<T>,T,U> |
PushStreamProvider.buildEventSourceFromStream(PushStream<T> stream) |
|
<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> BufferBuilder<SimplePushEventSource<T>,T,U> |
PushStreamProvider.buildSimpleEventSource(java.lang.Class<T> type) |
|
BufferBuilder<R,T,U> |
AbstractBufferBuilder.withBuffer(U queue) |
|
BufferBuilder<R,T,U> |
BufferBuilder.withBuffer(U queue) |
The BlockingQueue implementation to use as a buffer
|
BufferBuilder<R,T,U> |
AbstractBufferBuilder.withExecutor(java.util.concurrent.Executor executor) |
|
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.withParallelism(int parallelism) |
|
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.withPushbackPolicy(PushbackPolicy<T,U> pushbackPolicy) |
|
BufferBuilder<R,T,U> |
AbstractBufferBuilder.withPushbackPolicy(PushbackPolicyOption pushbackPolicyOption,
long time) |
|
BufferBuilder<R,T,U> |
BufferBuilder.withPushbackPolicy(PushbackPolicy<T,U> pushbackPolicy) |
|
BufferBuilder<R,T,U> |
BufferBuilder.withPushbackPolicy(PushbackPolicyOption pushbackPolicyOption,
long time) |
|
BufferBuilder<R,T,U> |
AbstractBufferBuilder.withQueuePolicy(QueuePolicy<T,U> queuePolicy) |
|
BufferBuilder<R,T,U> |
AbstractBufferBuilder.withQueuePolicy(QueuePolicyOption queuePolicyOption) |
|
BufferBuilder<R,T,U> |
BufferBuilder.withQueuePolicy(QueuePolicy<T,U> queuePolicy) |
|
BufferBuilder<R,T,U> |
BufferBuilder.withQueuePolicy(QueuePolicyOption queuePolicyOption) |
|
BufferBuilder<R,T,U> |
AbstractBufferBuilder.withScheduler(java.util.concurrent.ScheduledExecutorService scheduler) |
|
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
|