Uses of Interface
org.osgi.util.pushstream.PushStreamBuilder
-
Uses of PushStreamBuilder in org.osgi.util.pushstream
Modifier and TypeMethodDescription<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.PushStreamBuilder.withBuffer
(U queue) PushStreamBuilder.withExecutor
(Executor executor) PushStreamBuilder.withParallelism
(int parallelism) PushStreamBuilder.withPushbackPolicy
(PushbackPolicy<T, U> pushbackPolicy) PushStreamBuilder.withPushbackPolicy
(PushbackPolicyOption pushbackPolicyOption, long time) PushStreamBuilder.withQueuePolicy
(QueuePolicy<T, U> queuePolicy) PushStreamBuilder.withQueuePolicy
(QueuePolicyOption queuePolicyOption) PushStreamBuilder.withScheduler
(ScheduledExecutorService scheduler)