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

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

Modifier and Type	Method and Description
<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>	PushStreamBuilder.withBuffer(U queue)
PushStreamBuilder<T,U>	PushStreamBuilder.withExecutor(Executor executor)
PushStreamBuilder<T,U>	PushStreamBuilder.withParallelism(int parallelism)
PushStreamBuilder<T,U>	PushStreamBuilder.withPushbackPolicy(PushbackPolicy<T,U> pushbackPolicy)
PushStreamBuilder<T,U>	PushStreamBuilder.withPushbackPolicy(PushbackPolicyOption pushbackPolicyOption, long time)
PushStreamBuilder<T,U>	PushStreamBuilder.withQueuePolicy(QueuePolicy<T,U> queuePolicy)
PushStreamBuilder<T,U>	PushStreamBuilder.withQueuePolicy(QueuePolicyOption queuePolicyOption)
PushStreamBuilder<T,U>	PushStreamBuilder.withScheduler(ScheduledExecutorService scheduler)