Uses of Interface
org.osgi.util.pushstream.PushEventSource
-
Uses of PushEventSource in org.osgi.util.pushstream
Modifier and TypeInterfaceDescriptioninterface
ASimplePushEventSource
is a helper that makes it simpler to write aPushEventSource
.Modifier and TypeMethodDescription<T> PushEventSource<T>
PushStreamProvider.createEventSourceFromStream
(PushStream<T> stream) Convert anPushStream
into anPushEventSource
.Modifier and TypeMethodDescription<T,
U extends BlockingQueue<PushEvent<? extends T>>>
BufferBuilder<PushEventSource<T>,T, U> PushStreamProvider.buildEventSourceFromStream
(PushStream<T> stream) Convert anPushStream
into anPushEventSource
.Modifier 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.PushStream.merge
(PushEventSource<? extends T> source) Merge in the events from another source.