Package org.osgi.util.pushstream

Class AbstractBufferBuilder<R,T,U extends java.util.concurrent.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 java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
extends java.lang.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 java.util.concurrent.ScheduledExecutorService	timer
protected java.util.concurrent.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(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

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 Detail

worker

protected java.util.concurrent.Executor worker

timer

protected java.util.concurrent.ScheduledExecutorService timer

concurrency

protected int concurrency

backPressure

protected PushbackPolicy<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> backPressure

bufferingPolicy

protected QueuePolicy<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> bufferingPolicy

buffer

protected U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>> buffer

Constructor Detail

AbstractBufferBuilder

AbstractBufferBuilder()

Method Detail

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 java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>

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 java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>

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 java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>

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 java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>

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 java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>

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 java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>

Returns:

this builder

withExecutor

public BufferBuilder<R,T,U> withExecutor(java.util.concurrent.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 java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>

Returns:

this builder

withScheduler

public BufferBuilder<R,T,U> withScheduler(java.util.concurrent.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 java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>

Returns:

this builder