org.osgi.util.pushstream

Interface PushStreamBuilder<T,U extends BlockingQueue<PushEvent<? extends T>>>

Type Parameters:

T - The type of objects in the PushEvent

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

All Superinterfaces:

BufferBuilder<PushStream<T>,T,U>

@ProviderType
public interface PushStreamBuilder<T,U extends BlockingQueue<PushEvent<? extends T>>>
extends BufferBuilder<PushStream<T>,T,U>

A Builder for a PushStream. This Builder extends the support of a standard BufferBuilder by allowing the PushStream to be unbuffered.

Method Summary

Modifier and Type	Method and Description
PushStreamBuilder<T,U>	unbuffered() Tells this PushStreamBuilder to create an unbuffered stream which delivers events directly to its consumer using the incoming delivery thread.
PushStreamBuilder<T,U>	withBuffer(U queue) The BlockingQueue implementation to use as a buffer
PushStreamBuilder<T,U>	withExecutor(Executor executor) Set the Executor that should be used to deliver events from this buffer
PushStreamBuilder<T,U>	withParallelism(int parallelism) Set the maximum permitted number of concurrent event deliveries allowed from this buffer
PushStreamBuilder<T,U>	withPushbackPolicy(PushbackPolicy<T,U> pushbackPolicy) Set the PushbackPolicy of this builder
PushStreamBuilder<T,U>	withPushbackPolicy(PushbackPolicyOption pushbackPolicyOption, long time) Set the PushbackPolicy of this builder
PushStreamBuilder<T,U>	withQueuePolicy(QueuePolicy<T,U> queuePolicy) Set the QueuePolicy of this Builder
PushStreamBuilder<T,U>	withQueuePolicy(QueuePolicyOption queuePolicyOption) Set the QueuePolicy of this Builder
PushStreamBuilder<T,U>	withScheduler(ScheduledExecutorService scheduler) Set the ScheduledExecutorService that should be used to trigger timed events after this buffer

Methods inherited from interface org.osgi.util.pushstream.BufferBuilder

build

Method Detail

unbuffered

PushStreamBuilder<T,U> unbuffered()

Tells this PushStreamBuilder to create an unbuffered stream which delivers events directly to its consumer using the incoming delivery thread. Setting the PushStreamBuilder to be unbuffered means that any buffer, queue policy or push back policy will be ignored. Note that calling one of:

• withBuffer(BlockingQueue)
• withQueuePolicy(QueuePolicy)
• withQueuePolicy(QueuePolicyOption)
• withPushbackPolicy(PushbackPolicy)
• withPushbackPolicy(PushbackPolicyOption, long)
• withParallelism(int)

after this method will reset this builder to require a buffer.

Returns:

the builder

withBuffer

PushStreamBuilder<T,U> withBuffer(U queue)

Description copied from interface: BufferBuilder

The BlockingQueue implementation to use as a buffer

Specified by:

withBuffer in interface BufferBuilder<PushStream<T>,T,U extends BlockingQueue<PushEvent<? extends T>>>

Returns:

this builder

withQueuePolicy

PushStreamBuilder<T,U> withQueuePolicy(QueuePolicy<T,U> queuePolicy)

Description copied from interface: BufferBuilder

Set the QueuePolicy of this Builder

Specified by:

withQueuePolicy in interface BufferBuilder<PushStream<T>,T,U extends BlockingQueue<PushEvent<? extends T>>>

Returns:

this builder

withQueuePolicy

PushStreamBuilder<T,U> withQueuePolicy(QueuePolicyOption queuePolicyOption)

Description copied from interface: BufferBuilder

Set the QueuePolicy of this Builder

Specified by:

withQueuePolicy in interface BufferBuilder<PushStream<T>,T,U extends BlockingQueue<PushEvent<? extends T>>>

Returns:

this builder

withPushbackPolicy

PushStreamBuilder<T,U> withPushbackPolicy(PushbackPolicy<T,U> pushbackPolicy)

Description copied from interface: BufferBuilder

Set the PushbackPolicy of this builder

Specified by:

withPushbackPolicy in interface BufferBuilder<PushStream<T>,T,U extends BlockingQueue<PushEvent<? extends T>>>

Returns:

this builder

withPushbackPolicy

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

Description copied from interface: BufferBuilder

Set the PushbackPolicy of this builder

Specified by:

withPushbackPolicy in interface BufferBuilder<PushStream<T>,T,U extends BlockingQueue<PushEvent<? extends T>>>

Returns:

this builder

withParallelism

PushStreamBuilder<T,U> withParallelism(int parallelism)

Description copied from interface: BufferBuilder

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

Specified by:

withParallelism in interface BufferBuilder<PushStream<T>,T,U extends BlockingQueue<PushEvent<? extends T>>>

Returns:

this builder

withExecutor

PushStreamBuilder<T,U> withExecutor(Executor executor)

Description copied from interface: BufferBuilder

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

Specified by:

withExecutor in interface BufferBuilder<PushStream<T>,T,U extends BlockingQueue<PushEvent<? extends T>>>

Returns:

this builder

withScheduler

PushStreamBuilder<T,U> withScheduler(ScheduledExecutorService scheduler)

Description copied from interface: BufferBuilder

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

Specified by:

withScheduler in interface BufferBuilder<PushStream<T>,T,U extends BlockingQueue<PushEvent<? extends T>>>

Returns:

this builder