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 java.util.concurrent.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

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	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(java.util.concurrent.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(java.util.concurrent.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 java.util.concurrent.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 java.util.concurrent.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 java.util.concurrent.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 java.util.concurrent.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 java.util.concurrent.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 java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
    
    Returns:
    
    this builder
  - withExecutor
```
PushStreamBuilder<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<PushStream<T>,T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
    
    Returns:
    
    this builder
  - withScheduler
```
PushStreamBuilder<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<PushStream<T>,T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
    
    Returns:
    
    this builder

Interface PushStreamBuilder<T,​U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>

Method Summary

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

Method Detail

unbuffered

withBuffer

withQueuePolicy

withQueuePolicy

withPushbackPolicy

withPushbackPolicy

withParallelism

withExecutor

withScheduler

Interface PushStreamBuilder<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>