Package org.osgi.util.pushstream

Interface BufferBuilder<R,T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>

Type Parameters:

R - The type of object being built

T - The type of objects in the PushEvent

U - The type of the Queue used in the user specified buffer

All Known Subinterfaces:

PushStreamBuilder<T,U>

@ProviderType
public interface BufferBuilder<R,T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>

Create a buffered section of a Push-based stream

Method Summary

Modifier and Type	Method	Description
R	build()
BufferBuilder<R,T,U>	withBuffer(U queue)	The BlockingQueue implementation to use as a buffer
BufferBuilder<R,T,U>	withExecutor(java.util.concurrent.Executor executor)	Set the Executor that should be used to deliver events from this buffer
BufferBuilder<R,T,U>	withParallelism(int parallelism)	Set the maximum permitted number of concurrent event deliveries allowed from this buffer
BufferBuilder<R,T,U>	withPushbackPolicy(PushbackPolicy<T,U> pushbackPolicy)	Set the PushbackPolicy of this builder
BufferBuilder<R,T,U>	withPushbackPolicy(PushbackPolicyOption pushbackPolicyOption, long time)	Set the PushbackPolicy of this builder
BufferBuilder<R,T,U>	withQueuePolicy(QueuePolicy<T,U> queuePolicy)	Set the QueuePolicy of this Builder
BufferBuilder<R,T,U>	withQueuePolicy(QueuePolicyOption queuePolicyOption)	Set the QueuePolicy of this Builder
BufferBuilder<R,T,U>	withScheduler(java.util.concurrent.ScheduledExecutorService scheduler)	Set the ScheduledExecutorService that should be used to trigger timed events after this buffer

Method Detail

withBuffer

BufferBuilder<R,T,U> withBuffer(U queue)

The BlockingQueue implementation to use as a buffer

Parameters:

queue -

Returns:

this builder

withQueuePolicy

BufferBuilder<R,T,U> withQueuePolicy(QueuePolicy<T,U> queuePolicy)

Set the QueuePolicy of this Builder

Parameters:

queuePolicy -

Returns:

this builder

withQueuePolicy

BufferBuilder<R,T,U> withQueuePolicy(QueuePolicyOption queuePolicyOption)

Set the QueuePolicy of this Builder

Parameters:

queuePolicyOption -

Returns:

this builder

withPushbackPolicy

BufferBuilder<R,T,U> withPushbackPolicy(PushbackPolicy<T,U> pushbackPolicy)

Set the PushbackPolicy of this builder

Parameters:

pushbackPolicy -

Returns:

this builder

withPushbackPolicy

BufferBuilder<R,T,U> withPushbackPolicy(PushbackPolicyOption pushbackPolicyOption,
                                                    long time)

Set the PushbackPolicy of this builder

Parameters:

pushbackPolicyOption -

time -

Returns:

this builder

withParallelism

BufferBuilder<R,T,U> withParallelism(int parallelism)

Set the maximum permitted number of concurrent event deliveries allowed from this buffer

Parameters:

parallelism -

Returns:

this builder

withExecutor

BufferBuilder<R,T,U> withExecutor(java.util.concurrent.Executor executor)

Set the Executor that should be used to deliver events from this buffer

Parameters:

executor -

Returns:

this builder

withScheduler

BufferBuilder<R,T,U> withScheduler(java.util.concurrent.ScheduledExecutorService scheduler)

Set the ScheduledExecutorService that should be used to trigger timed events after this buffer

Parameters:

scheduler -

Returns:

this builder

build

R build()

Returns:

the object being built