Uses of Interface
org.osgi.util.pushstream.PushEventSource
Packages that use PushEventSource
-
Uses of PushEventSource in org.osgi.util.pushstream
Subinterfaces of PushEventSource in org.osgi.util.pushstreamModifier and TypeInterfaceDescriptioninterface
ASimplePushEventSource
is a helper that makes it simpler to write aPushEventSource
.Classes in org.osgi.util.pushstream that implement PushEventSourceModifier and TypeClassDescription(package private) static final class
(package private) class
SimplePushEventSourceImpl<T,
U extends BlockingQueue<PushEvent<? extends T>>> Fields in org.osgi.util.pushstream declared as PushEventSourceModifier and TypeFieldDescriptionprivate final PushEventSource
<T> PushStreamBuilderImpl.eventSource
Methods in org.osgi.util.pushstream that return PushEventSourceModifier and TypeMethodDescription<T> PushEventSource
<T> PushStreamProvider.createEventSourceFromStream
(PushStream<T> stream) Convert anPushStream
into anPushEventSource
.Methods in org.osgi.util.pushstream that return types with arguments of type PushEventSourceModifier and TypeMethodDescription<T,
U extends BlockingQueue<PushEvent<? extends T>>>
BufferBuilder<PushEventSource<T>, T, U> PushStreamProvider.buildEventSourceFromStream
(PushStream<T> stream) Convert anPushStream
into anPushEventSource
.Methods in org.osgi.util.pushstream with parameters of type PushEventSourceModifier and TypeMethodDescription<T,
U extends BlockingQueue<PushEvent<? extends T>>>
PushStreamBuilder<T, U> PushStreamProvider.buildStream
(PushEventSource<T> eventSource) Builds a push stream with custom configuration.<T> PushStream
<T> PushStreamProvider.createStream
(PushEventSource<T> eventSource) Create a stream with the default configured buffer, executor size, queue, queue policy and pushback policy.(package private) <T,
U extends BlockingQueue<PushEvent<? extends T>>>
PushStream<T> PushStreamProvider.createStream
(PushEventSource<T> eventSource, int parallelism, Executor executor, ScheduledExecutorService scheduler, U queue, QueuePolicy<T, U> queuePolicy, PushbackPolicy<T, U> pushbackPolicy) (package private) <T> PushStream
<T> PushStreamProvider.createUnbufferedStream
(PushEventSource<T> eventSource, Executor executor, ScheduledExecutorService scheduler) AbstractPushStreamImpl.merge
(PushEventSource<? extends T> source) PushStream.merge
(PushEventSource<? extends T> source) Merge in the events from another source.Constructors in org.osgi.util.pushstream with parameters of type PushEventSourceModifierConstructorDescription(package private)
PushStreamBuilderImpl
(PushStreamProvider psp, Executor defaultExecutor, ScheduledExecutorService defaultScheduler, PushEventSource<T> eventSource)