Uses of Interface
org.osgi.util.pushstream.BufferBuilder
Packages that use BufferBuilder
-
Uses of BufferBuilder in org.osgi.util.pushstream
Subinterfaces of BufferBuilder in org.osgi.util.pushstreamModifier and TypeInterfaceDescriptioninterface
PushStreamBuilder<T,
U extends BlockingQueue<PushEvent<? extends T>>> A Builder for a PushStream.Methods in org.osgi.util.pushstream that return BufferBuilderModifier and TypeMethodDescription<T,
U extends BlockingQueue<PushEvent<? extends T>>>
BufferBuilder<PushEventConsumer<T>, T, U> PushStreamProvider.buildBufferedConsumer
(PushEventConsumer<T> delegate) Build a bufferedPushEventConsumer
with custom configuration.<T,
U extends BlockingQueue<PushEvent<? extends T>>>
BufferBuilder<PushEventSource<T>, T, U> PushStreamProvider.buildEventSourceFromStream
(PushStream<T> stream) Convert anPushStream
into anPushEventSource
.<T,
U extends BlockingQueue<PushEvent<? extends T>>>
BufferBuilder<SimplePushEventSource<T>, T, U> PushStreamProvider.buildSimpleEventSource
(Class<T> type) Build aSimplePushEventSource
with the supplied type and custom buffering behaviors.BufferBuilder
<R, T, U> BufferBuilder.withBuffer
(U queue) The BlockingQueue implementation to use as a bufferBufferBuilder
<R, T, U> BufferBuilder.withExecutor
(Executor executor) Set theExecutor
that should be used to deliver events from this bufferBufferBuilder
<R, T, U> BufferBuilder.withParallelism
(int parallelism) Set the maximum permitted number of concurrent event deliveries allowed from this bufferBufferBuilder
<R, T, U> BufferBuilder.withPushbackPolicy
(PushbackPolicy<T, U> pushbackPolicy) Set thePushbackPolicy
of this builderBufferBuilder
<R, T, U> BufferBuilder.withPushbackPolicy
(PushbackPolicyOption pushbackPolicyOption, long time) Set thePushbackPolicy
of this builderBufferBuilder
<R, T, U> BufferBuilder.withQueuePolicy
(QueuePolicy<T, U> queuePolicy) Set theQueuePolicy
of this BuilderBufferBuilder
<R, T, U> BufferBuilder.withQueuePolicy
(QueuePolicyOption queuePolicyOption) Set theQueuePolicy
of this BuilderBufferBuilder
<R, T, U> BufferBuilder.withScheduler
(ScheduledExecutorService scheduler) Set theScheduledExecutorService
that should be used to trigger timed events after this buffer