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

Packages that use PushStreamBuilder

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

Uses of PushStreamBuilder in org.osgi.util.pushstream

Classes in org.osgi.util.pushstream that implement PushStreamBuilder

Modifier and Type	Class	Description
(package private) class	PushStreamBuilderImpl<T,U extends BlockingQueue<PushEvent<? extends T>>>

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

Modifier and Type	Method	Description
<U extends BlockingQueue<PushEvent<? extends T>>> PushStreamBuilder<T,U>	AbstractPushStreamImpl.buildBuffer()
<U extends BlockingQueue<PushEvent<? extends T>>> PushStreamBuilder<T,U>	PushStream.buildBuffer()	Build a buffer to enqueue events in a queue using custom values for the queue size and other behaviors.
<T, U extends BlockingQueue<PushEvent<? extends T>>> PushStreamBuilder<T,U>	PushStreamProvider.buildStream(PushEventSource<T> eventSource)	Builds a push stream with custom configuration.
PushStreamBuilder<T,U>	PushStreamBuilder.unbuffered()	Tells this PushStreamBuilder to create an unbuffered stream which delivers events directly to its consumer using the incoming delivery thread.
PushStreamBuilder<T,U>	PushStreamBuilderImpl.unbuffered()
PushStreamBuilder<T,U>	PushStreamBuilder.withBuffer(U queue)
PushStreamBuilder<T,U>	PushStreamBuilderImpl.withBuffer(U queue)
PushStreamBuilder<T,U>	PushStreamBuilder.withExecutor(Executor executor)
PushStreamBuilder<T,U>	PushStreamBuilderImpl.withExecutor(Executor executor)
PushStreamBuilder<T,U>	PushStreamBuilder.withParallelism(int parallelism)
PushStreamBuilder<T,U>	PushStreamBuilderImpl.withParallelism(int parallelism)
PushStreamBuilder<T,U>	PushStreamBuilder.withPushbackPolicy(PushbackPolicy<T,U> pushbackPolicy)
PushStreamBuilder<T,U>	PushStreamBuilder.withPushbackPolicy(PushbackPolicyOption pushbackPolicyOption, long time)
PushStreamBuilder<T,U>	PushStreamBuilderImpl.withPushbackPolicy(PushbackPolicy<T,U> pushbackPolicy)
PushStreamBuilder<T,U>	PushStreamBuilderImpl.withPushbackPolicy(PushbackPolicyOption pushbackPolicyOption, long time)
PushStreamBuilder<T,U>	PushStreamBuilder.withQueuePolicy(QueuePolicy<T,U> queuePolicy)
PushStreamBuilder<T,U>	PushStreamBuilder.withQueuePolicy(QueuePolicyOption queuePolicyOption)
PushStreamBuilder<T,U>	PushStreamBuilderImpl.withQueuePolicy(QueuePolicy<T,U> queuePolicy)
PushStreamBuilder<T,U>	PushStreamBuilderImpl.withQueuePolicy(QueuePolicyOption queuePolicyOption)
PushStreamBuilder<T,U>	PushStreamBuilder.withScheduler(ScheduledExecutorService scheduler)
PushStreamBuilder<T,U>	PushStreamBuilderImpl.withScheduler(ScheduledExecutorService scheduler)