?? PushStreamBuilder<T,U extends BlockingQueue<PushEvent<? extends T>>>
- ????:
T
- The type of objects in thePushEvent
U
- The type of the Queue used in the user specified buffer
- ??????:
BufferBuilder<PushStream<T>,
T, U>
@ProviderType
public interface PushStreamBuilder<T,U extends 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.
-
????
??????????Tells thisPushStreamBuilder
to create an unbuffered stream which delivers events directly to its consumer using the incoming delivery thread.withBuffer
(U queue) The BlockingQueue implementation to use as a bufferwithExecutor
(Executor executor) Set theExecutor
that should be used to deliver events from this bufferwithParallelism
(int parallelism) Set the maximum permitted number of concurrent event deliveries allowed from this bufferwithPushbackPolicy
(PushbackPolicy<T, U> pushbackPolicy) Set thePushbackPolicy
of this builderwithPushbackPolicy
(PushbackPolicyOption pushbackPolicyOption, long time) Set thePushbackPolicy
of this builderwithQueuePolicy
(QueuePolicy<T, U> queuePolicy) Set theQueuePolicy
of this BuilderwithQueuePolicy
(QueuePolicyOption queuePolicyOption) Set theQueuePolicy
of this BuilderwithScheduler
(ScheduledExecutorService scheduler) Set theScheduledExecutorService
that should be used to trigger timed events after this buffer???????? org.osgi.util.pushstream.BufferBuilder
build
-
??????
-
unbuffered
PushStreamBuilder<T,U> unbuffered()Tells thisPushStreamBuilder
to create an unbuffered stream which delivers events directly to its consumer using the incoming delivery thread. Setting thePushStreamBuilder
to be unbuffered means that any buffer, queue policy or push back policy will be ignored. Note that calling one of: after this method will reset this builder to require a buffer.- ??:
- the builder
-
withBuffer
????????:BufferBuilder
The BlockingQueue implementation to use as a buffer- ???:
withBuffer
????BufferBuilder<PushStream<T>,
T, U extends BlockingQueue<PushEvent<? extends T>>> - ??:
- this builder
-
withQueuePolicy
????????:BufferBuilder
Set theQueuePolicy
of this Builder- ???:
withQueuePolicy
????BufferBuilder<PushStream<T>,
T, U extends BlockingQueue<PushEvent<? extends T>>> - ??:
- this builder
-
withQueuePolicy
????????:BufferBuilder
Set theQueuePolicy
of this Builder- ???:
withQueuePolicy
????BufferBuilder<PushStream<T>,
T, U extends BlockingQueue<PushEvent<? extends T>>> - ??:
- this builder
-
withPushbackPolicy
????????:BufferBuilder
Set thePushbackPolicy
of this builder- ???:
withPushbackPolicy
????BufferBuilder<PushStream<T>,
T, U extends BlockingQueue<PushEvent<? extends T>>> - ??:
- this builder
-
withPushbackPolicy
????????:BufferBuilder
Set thePushbackPolicy
of this builder- ???:
withPushbackPolicy
????BufferBuilder<PushStream<T>,
T, U extends BlockingQueue<PushEvent<? extends T>>> - ??:
- this builder
-
withParallelism
????????:BufferBuilder
Set the maximum permitted number of concurrent event deliveries allowed from this buffer- ???:
withParallelism
????BufferBuilder<PushStream<T>,
T, U extends BlockingQueue<PushEvent<? extends T>>> - ??:
- this builder
-
withExecutor
????????:BufferBuilder
Set theExecutor
that should be used to deliver events from this buffer- ???:
withExecutor
????BufferBuilder<PushStream<T>,
T, U extends BlockingQueue<PushEvent<? extends T>>> - ??:
- this builder
-
withScheduler
????????:BufferBuilder
Set theScheduledExecutorService
that should be used to trigger timed events after this buffer- ???:
withScheduler
????BufferBuilder<PushStream<T>,
T, U extends BlockingQueue<PushEvent<? extends T>>> - ??:
- this builder
-