Package org.osgi.util.pushstream

Class PushStreamBuilderImpl<T,U extends BlockingQueue<PushEvent<? extends T>>>

java.lang.Object

org.osgi.util.pushstream.AbstractBufferBuilder<PushStream<T>,T,U>

org.osgi.util.pushstream.PushStreamBuilderImpl<T,U>

All Implemented Interfaces:

BufferBuilder<PushStream<T>,T,U>, PushStreamBuilder<T,U>

class PushStreamBuilderImpl<T,U extends BlockingQueue<PushEvent<? extends T>>>
extends AbstractBufferBuilder<PushStream<T>,T,U>
implements PushStreamBuilder<T,U>

Field Summary

Fields

Modifier and Type	Field	Description
private final PushEventSource<T>	eventSource
private final Executor	previousExecutor
private final ScheduledExecutorService	previousScheduler
private final PushStreamProvider	psp
private boolean	unbuffered

Fields inherited from class org.osgi.util.pushstream.AbstractBufferBuilder

backPressure, buffer, bufferingPolicy, concurrency, timer, worker

Constructor Summary

Constructors

Constructor	Description
PushStreamBuilderImpl(PushStreamProvider psp, Executor defaultExecutor, ScheduledExecutorService defaultScheduler, PushEventSource<T> eventSource)

Method Summary

Modifier and Type	Method	Description
PushStream<T>	build()
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 class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

psp

private final PushStreamProvider psp

eventSource

private final PushEventSource<T> eventSource

previousExecutor

private final Executor previousExecutor

previousScheduler

private final ScheduledExecutorService previousScheduler

unbuffered

private boolean unbuffered

Constructor Details

PushStreamBuilderImpl

PushStreamBuilderImpl(PushStreamProvider psp,
 Executor defaultExecutor,
 ScheduledExecutorService defaultScheduler,
 PushEventSource<T> eventSource)

Method Details

withBuffer

public 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>>>

Specified by:

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

Overrides:

withBuffer in class AbstractBufferBuilder<PushStream<T>,T,U extends BlockingQueue<PushEvent<? extends T>>>

Parameters:

queue -

Returns:

this builder

withQueuePolicy

public 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>>>

Specified by:

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

Overrides:

withQueuePolicy in class AbstractBufferBuilder<PushStream<T>,T,U extends BlockingQueue<PushEvent<? extends T>>>

Parameters:

queuePolicy -

Returns:

this builder

withQueuePolicy

public 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>>>

Specified by:

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

Overrides:

withQueuePolicy in class AbstractBufferBuilder<PushStream<T>,T,U extends BlockingQueue<PushEvent<? extends T>>>

Parameters:

queuePolicyOption -

Returns:

this builder

withPushbackPolicy

public 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>>>

Specified by:

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

Overrides:

withPushbackPolicy in class AbstractBufferBuilder<PushStream<T>,T,U extends BlockingQueue<PushEvent<? extends T>>>

Parameters:

pushbackPolicy -

Returns:

this builder

withPushbackPolicy

public 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>>>

Specified by:

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

Overrides:

withPushbackPolicy in class AbstractBufferBuilder<PushStream<T>,T,U extends BlockingQueue<PushEvent<? extends T>>>

Parameters:

pushbackPolicyOption -

time -

Returns:

this builder

withParallelism

public 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>>>

Specified by:

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

Overrides:

withParallelism in class AbstractBufferBuilder<PushStream<T>,T,U extends BlockingQueue<PushEvent<? extends T>>>

Parameters:

parallelism -

Returns:

this builder

withExecutor

public 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>>>

Specified by:

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

Overrides:

withExecutor in class AbstractBufferBuilder<PushStream<T>,T,U extends BlockingQueue<PushEvent<? extends T>>>

Parameters:

executor -

Returns:

this builder

withScheduler

public 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>>>

Specified by:

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

Overrides:

withScheduler in class AbstractBufferBuilder<PushStream<T>,T,U extends BlockingQueue<PushEvent<? extends T>>>

Parameters:

scheduler -

Returns:

this builder

unbuffered

public PushStreamBuilder<T,U> unbuffered()

Description copied from interface: PushStreamBuilder

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:

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

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

Specified by:

unbuffered in interface PushStreamBuilder<T,U extends BlockingQueue<PushEvent<? extends T>>>

Returns:

the builder

build

public PushStream<T> build()

Specified by:

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

Returns:

the object being built