Package org.osgi.util.pushstream

Class AbstractBufferBuilder<R,T,U extends BlockingQueue<PushEvent<? extends T>>>

java.lang.Object

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

All Implemented Interfaces:

BufferBuilder<R,T,U>

Direct Known Subclasses:

PushStreamBuilderImpl

abstract class AbstractBufferBuilder<R,T,U extends BlockingQueue<PushEvent<? extends T>>>
extends Object
implements BufferBuilder<R,T,U>

Field Summary

Fields

Modifier and Type	Field	Description
protected PushbackPolicy<T,U>	backPressure
protected U	buffer
protected QueuePolicy<T,U>	bufferingPolicy
protected int	concurrency
protected ScheduledExecutorService	timer
protected Executor	worker

Constructor Summary

Constructors

Constructor	Description
AbstractBufferBuilder()

Method Summary

Modifier and Type	Method	Description
BufferBuilder<R,T,U>	withBuffer(U queue)	The BlockingQueue implementation to use as a buffer
BufferBuilder<R,T,U>	withExecutor(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(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

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

build

Field Details

worker

protected Executor worker

timer

protected ScheduledExecutorService timer

concurrency

protected int concurrency

backPressure

protected PushbackPolicy<T,U extends BlockingQueue<PushEvent<? extends T>>> backPressure

bufferingPolicy

protected QueuePolicy<T,U extends BlockingQueue<PushEvent<? extends T>>> bufferingPolicy

buffer

protected U extends BlockingQueue<PushEvent<? extends T>> buffer

Constructor Details

AbstractBufferBuilder

AbstractBufferBuilder()

Method Details

withBuffer

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

Description copied from interface: BufferBuilder

The BlockingQueue implementation to use as a buffer

Specified by:

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

Parameters:

queue -

Returns:

this builder

withQueuePolicy

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

Description copied from interface: BufferBuilder

Set the QueuePolicy of this Builder

Specified by:

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

Parameters:

queuePolicy -

Returns:

this builder

withQueuePolicy

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

Description copied from interface: BufferBuilder

Set the QueuePolicy of this Builder

Specified by:

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

Parameters:

queuePolicyOption -

Returns:

this builder

withPushbackPolicy

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

Description copied from interface: BufferBuilder

Set the PushbackPolicy of this builder

Specified by:

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

Parameters:

pushbackPolicy -

Returns:

this builder

withPushbackPolicy

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

Description copied from interface: BufferBuilder

Set the PushbackPolicy of this builder

Specified by:

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

Parameters:

pushbackPolicyOption -

time -

Returns:

this builder

withParallelism

public BufferBuilder<R,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<R,T,U extends BlockingQueue<PushEvent<? extends T>>>

Parameters:

parallelism -

Returns:

this builder

withExecutor

public BufferBuilder<R,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<R,T,U extends BlockingQueue<PushEvent<? extends T>>>

Parameters:

executor -

Returns:

this builder

withScheduler

public BufferBuilder<R,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<R,T,U extends BlockingQueue<PushEvent<? extends T>>>

Parameters:

scheduler -

Returns:

this builder