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 java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
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>AbstractPushStreamImpl. buildBuffer()
<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 thisPushStreamBuilder
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(java.util.concurrent.Executor executor)
PushStreamBuilder<T,U>
PushStreamBuilderImpl. withExecutor(java.util.concurrent.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(java.util.concurrent.ScheduledExecutorService scheduler)
PushStreamBuilder<T,U>
PushStreamBuilderImpl. withScheduler(java.util.concurrent.ScheduledExecutorService scheduler)
-