Uses of Interface
org.osgi.util.pushstream.BufferBuilder

Packages that use BufferBuilder

Package	Description
org.osgi.util.pushstream	Push Stream Package Version 1.0.

Uses of BufferBuilder in org.osgi.util.pushstream

Subinterfaces of BufferBuilder in org.osgi.util.pushstream

Modifier and Type	Interface and Description
interface	PushStreamBuilder<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> A Builder for a PushStream.

Methods in org.osgi.util.pushstream that return BufferBuilder

Modifier and Type	Method and Description
<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> BufferBuilder<PushEventConsumer<T>,T,U>	PushStreamProvider.buildBufferedConsumer(PushEventConsumer<T> delegate) Build a buffered PushEventConsumer with custom configuration.
<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> BufferBuilder<PushEventSource<T>,T,U>	PushStreamProvider.buildEventSourceFromStream(PushStream<T> stream) Convert an PushStream into an PushEventSource.
<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> BufferBuilder<SimplePushEventSource<T>,T,U>	PushStreamProvider.buildSimpleEventSource(java.lang.Class<T> type) Build a SimplePushEventSource with the supplied type and custom buffering behaviors.
BufferBuilder<R,T,U>	BufferBuilder.withBuffer(U queue) The BlockingQueue implementation to use as a buffer
BufferBuilder<R,T,U>	BufferBuilder.withExecutor(java.util.concurrent.Executor executor) Set the Executor that should be used to deliver events from this buffer
BufferBuilder<R,T,U>	BufferBuilder.withParallelism(int parallelism) Set the maximum permitted number of concurrent event deliveries allowed from this buffer
BufferBuilder<R,T,U>	BufferBuilder.withPushbackPolicy(PushbackPolicy<T,U> pushbackPolicy) Set the PushbackPolicy of this builder
BufferBuilder<R,T,U>	BufferBuilder.withPushbackPolicy(PushbackPolicyOption pushbackPolicyOption, long time) Set the PushbackPolicy of this builder
BufferBuilder<R,T,U>	BufferBuilder.withQueuePolicy(QueuePolicy<T,U> queuePolicy) Set the QueuePolicy of this Builder
BufferBuilder<R,T,U>	BufferBuilder.withQueuePolicy(QueuePolicyOption queuePolicyOption) Set the QueuePolicy of this Builder
BufferBuilder<R,T,U>	BufferBuilder.withScheduler(java.util.concurrent.ScheduledExecutorService scheduler) Set the ScheduledExecutorService that should be used to trigger timed events after this buffer