Uses of Interface
org.osgi.util.pushstream.PushStreamBuilder
Packages that use PushStreamBuilder
-
Uses of PushStreamBuilder in org.osgi.util.pushstream
Classes in org.osgi.util.pushstream that implement PushStreamBuilderModifier and TypeClassDescription(package private) class
PushStreamBuilderImpl<T,
U extends BlockingQueue<PushEvent<? extends T>>> Methods in org.osgi.util.pushstream that return PushStreamBuilderModifier and TypeMethodDescription<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.unbuffered()
Tells thisPushStreamBuilder
to create an unbuffered stream which delivers events directly to its consumer using the incoming delivery thread.PushStreamBuilderImpl.unbuffered()
PushStreamBuilder.withBuffer
(U queue) PushStreamBuilderImpl.withBuffer
(U queue) PushStreamBuilder.withExecutor
(Executor executor) PushStreamBuilderImpl.withExecutor
(Executor executor) PushStreamBuilder.withParallelism
(int parallelism) PushStreamBuilderImpl.withParallelism
(int parallelism) PushStreamBuilder.withPushbackPolicy
(PushbackPolicy<T, U> pushbackPolicy) PushStreamBuilder.withPushbackPolicy
(PushbackPolicyOption pushbackPolicyOption, long time) PushStreamBuilderImpl.withPushbackPolicy
(PushbackPolicy<T, U> pushbackPolicy) PushStreamBuilderImpl.withPushbackPolicy
(PushbackPolicyOption pushbackPolicyOption, long time) PushStreamBuilder.withQueuePolicy
(QueuePolicy<T, U> queuePolicy) PushStreamBuilder.withQueuePolicy
(QueuePolicyOption queuePolicyOption) PushStreamBuilderImpl.withQueuePolicy
(QueuePolicy<T, U> queuePolicy) PushStreamBuilderImpl.withQueuePolicy
(QueuePolicyOption queuePolicyOption) PushStreamBuilder.withScheduler
(ScheduledExecutorService scheduler) PushStreamBuilderImpl.withScheduler
(ScheduledExecutorService scheduler)