Top Fields Constructors Methods
org.osgi.util.pushstream

pack-priv abstract Class AbstractBufferBuilder<R, T, U extends BlockingQueue<PushEvent<? extends T>>>

extends Object
implements BufferBuilder<R, T, U extends BlockingQueue<PushEvent<? extends T>>>
Class Inheritance
All Implemented Interfaces
org.osgi.util.pushstream.BufferBuilder
Known Direct Subclasses
org.osgi.util.pushstream.PushStreamBuilderImpl
Imports
java.util.concurrent.BlockingQueue, .Executor, .ScheduledExecutorService

Field Summary

Modifier and TypeField and 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

AccessConstructor and Description
pack-priv
AbstractBufferBuilder()

Method Summary

Modifier and TypeMethod and Description
public BufferBuilder<R, T, U>
withBuffer(U queue)

Implements org.osgi.util.pushstream.BufferBuilder.withBuffer.

The BlockingQueue implementation to use as a buffer

public BufferBuilder<R, T, U>
withExecutor(Executor executor)

Implements org.osgi.util.pushstream.BufferBuilder.withExecutor.

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

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

Implements org.osgi.util.pushstream.BufferBuilder.withParallelism.

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

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

Implements org.osgi.util.pushstream.BufferBuilder.withPushbackPolicy.

Set the PushbackPolicy of this builder

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

Implements org.osgi.util.pushstream.BufferBuilder.withPushbackPolicy.

Set the PushbackPolicy of this builder

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

Implements org.osgi.util.pushstream.BufferBuilder.withQueuePolicy.

Set the QueuePolicy of this Builder

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

Implements org.osgi.util.pushstream.BufferBuilder.withQueuePolicy.

Set the QueuePolicy of this Builder

public BufferBuilder<R, T, U>
withScheduler(ScheduledExecutorService scheduler)

Implements org.osgi.util.pushstream.BufferBuilder.withScheduler.

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

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

backPressureback to summary
protected PushbackPolicy<T, U> backPressure
bufferback to summary
protected U buffer
bufferingPolicyback to summary
protected QueuePolicy<T, U> bufferingPolicy
concurrencyback to summary
protected int concurrency
timerback to summary
protected ScheduledExecutorService timer
workerback to summary
protected Executor worker

Constructor Detail

AbstractBufferBuilderback to summary
pack-priv AbstractBufferBuilder()

Method Detail

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

Implements org.osgi.util.pushstream.BufferBuilder.withBuffer.

Doc from org.osgi.util.pushstream.BufferBuilder.withBuffer.

The BlockingQueue implementation to use as a buffer

Returns:BufferBuilder<R, T, U>

this builder

Annotations
@Override
withExecutorback to summary
public BufferBuilder<R, T, U> withExecutor(Executor executor)

Implements org.osgi.util.pushstream.BufferBuilder.withExecutor.

Doc from org.osgi.util.pushstream.BufferBuilder.withExecutor.

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

Returns:BufferBuilder<R, T, U>

this builder

Annotations
@Override
withParallelismback to summary
public BufferBuilder<R, T, U> withParallelism(int parallelism)

Implements org.osgi.util.pushstream.BufferBuilder.withParallelism.

Doc from org.osgi.util.pushstream.BufferBuilder.withParallelism.

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

Returns:BufferBuilder<R, T, U>

this builder

Annotations
@Override
withPushbackPolicyback to summary
public BufferBuilder<R, T, U> withPushbackPolicy(PushbackPolicy<T, U> pushbackPolicy)

Implements org.osgi.util.pushstream.BufferBuilder.withPushbackPolicy.

Doc from org.osgi.util.pushstream.BufferBuilder.withPushbackPolicy.

Set the PushbackPolicy of this builder

Returns:BufferBuilder<R, T, U>

this builder

Annotations
@Override
withPushbackPolicyback to summary
public BufferBuilder<R, T, U> withPushbackPolicy(PushbackPolicyOption pushbackPolicyOption, long time)

Implements org.osgi.util.pushstream.BufferBuilder.withPushbackPolicy.

Doc from org.osgi.util.pushstream.BufferBuilder.withPushbackPolicy.

Set the PushbackPolicy of this builder

Returns:BufferBuilder<R, T, U>

this builder

Annotations
@Override
withQueuePolicyback to summary
public BufferBuilder<R, T, U> withQueuePolicy(QueuePolicy<T, U> queuePolicy)

Implements org.osgi.util.pushstream.BufferBuilder.withQueuePolicy.

Doc from org.osgi.util.pushstream.BufferBuilder.withQueuePolicy.

Set the QueuePolicy of this Builder

Returns:BufferBuilder<R, T, U>

this builder

Annotations
@Override
withQueuePolicyback to summary
public BufferBuilder<R, T, U> withQueuePolicy(QueuePolicyOption queuePolicyOption)

Implements org.osgi.util.pushstream.BufferBuilder.withQueuePolicy.

Doc from org.osgi.util.pushstream.BufferBuilder.withQueuePolicy.

Set the QueuePolicy of this Builder

Returns:BufferBuilder<R, T, U>

this builder

Annotations
@Override
withSchedulerback to summary
public BufferBuilder<R, T, U> withScheduler(ScheduledExecutorService scheduler)

Implements org.osgi.util.pushstream.BufferBuilder.withScheduler.

Doc from org.osgi.util.pushstream.BufferBuilder.withScheduler.

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

Returns:BufferBuilder<R, T, U>

this builder

Annotations
@Override