?? BufferBuilder<R,T,U extends BlockingQueue<PushEvent<? extends T>>>
- ????:
R
- The type of object being builtT
- The type of objects in thePushEvent
U
- The type of the Queue used in the user specified buffer
- ???????:
PushStreamBuilder<T,
U>
Create a buffered section of a Push-based stream
-
????
??????????build()
BufferBuilder<R,
T, U> withBuffer
(U queue) The BlockingQueue implementation to use as a bufferBufferBuilder<R,
T, U> withExecutor
(Executor executor) Set theExecutor
that should be used to deliver events from this bufferBufferBuilder<R,
T, U> withParallelism
(int parallelism) Set the maximum permitted number of concurrent event deliveries allowed from this bufferBufferBuilder<R,
T, U> withPushbackPolicy
(PushbackPolicy<T, U> pushbackPolicy) Set thePushbackPolicy
of this builderBufferBuilder<R,
T, U> withPushbackPolicy
(PushbackPolicyOption pushbackPolicyOption, long time) Set thePushbackPolicy
of this builderBufferBuilder<R,
T, U> withQueuePolicy
(QueuePolicy<T, U> queuePolicy) Set theQueuePolicy
of this BuilderBufferBuilder<R,
T, U> withQueuePolicy
(QueuePolicyOption queuePolicyOption) Set theQueuePolicy
of this BuilderBufferBuilder<R,
T, U> withScheduler
(ScheduledExecutorService scheduler) Set theScheduledExecutorService
that should be used to trigger timed events after this buffer
-
??????
-
withBuffer
The BlockingQueue implementation to use as a buffer- ??:
queue
-- ??:
- this builder
-
withQueuePolicy
Set theQueuePolicy
of this Builder- ??:
queuePolicy
-- ??:
- this builder
-
withQueuePolicy
Set theQueuePolicy
of this Builder- ??:
queuePolicyOption
-- ??:
- this builder
-
withPushbackPolicy
Set thePushbackPolicy
of this builder- ??:
pushbackPolicy
-- ??:
- this builder
-
withPushbackPolicy
Set thePushbackPolicy
of this builder- ??:
pushbackPolicyOption
-time
-- ??:
- this builder
-
withParallelism
Set the maximum permitted number of concurrent event deliveries allowed from this buffer- ??:
parallelism
-- ??:
- this builder
-
withExecutor
Set theExecutor
that should be used to deliver events from this buffer- ??:
executor
-- ??:
- this builder
-
withScheduler
Set theScheduledExecutorService
that should be used to trigger timed events after this buffer- ??:
scheduler
-- ??:
- this builder
-
build
R build()- ??:
- the object being built
-