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 Description <U extends java.util.concurrent.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 java.util.concurrent.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 thisPushStreamBuilderto 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(java.util.concurrent.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(java.util.concurrent.ScheduledExecutorService scheduler)
-