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 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 BlockingQueue<PushEvent<? extends T>>> BufferBuilder<PushEventConsumer<T>,T,U>	PushStreamProvider.buildBufferedConsumer(PushEventConsumer<T> delegate) Build a buffered PushEventConsumer with custom configuration.
<T,U extends BlockingQueue<PushEvent<? extends T>>> BufferBuilder<PushEventSource<T>,T,U>	PushStreamProvider.buildEventSourceFromStream(PushStream<T> stream) Convert an PushStream into an PushEventSource.
<T,U extends BlockingQueue<PushEvent<? extends T>>> BufferBuilder<SimplePushEventSource<T>,T,U>	PushStreamProvider.buildSimpleEventSource(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(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(ScheduledExecutorService scheduler) Set the ScheduledExecutorService that should be used to trigger timed events after this buffer