Uses of Interface
org.osgi.util.pushstream.PushEventSource
-
Packages that use PushEventSource Package Description org.osgi.util.pushstream Push Stream Package Version 1.0. -
-
Uses of PushEventSource in org.osgi.util.pushstream
Subinterfaces of PushEventSource in org.osgi.util.pushstream Modifier and Type Interface Description interface
SimplePushEventSource<T>
ASimplePushEventSource
is a helper that makes it simpler to write aPushEventSource
.Classes in org.osgi.util.pushstream that implement PushEventSource Modifier and Type Class Description (package private) static class
PushStreamProvider.PushEventPipe<T>
(package private) class
SimplePushEventSourceImpl<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
Fields in org.osgi.util.pushstream declared as PushEventSource Modifier and Type Field Description private PushEventSource<T>
PushStreamBuilderImpl. eventSource
Methods in org.osgi.util.pushstream that return PushEventSource Modifier and Type Method Description <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 PushEventSource Modifier and Type Method Description <T,U extends java.util.concurrent.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 PushEventSource Modifier and Type Method Description <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.<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 java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
PushStream<T>PushStreamProvider. createStream(PushEventSource<T> eventSource, int parallelism, java.util.concurrent.Executor executor, java.util.concurrent.ScheduledExecutorService scheduler, U queue, QueuePolicy<T,U> queuePolicy, PushbackPolicy<T,U> pushbackPolicy)
(package private) <T> PushStream<T>
PushStreamProvider. createUnbufferedStream(PushEventSource<T> eventSource, java.util.concurrent.Executor executor, java.util.concurrent.ScheduledExecutorService scheduler)
PushStream<T>
AbstractPushStreamImpl. merge(PushEventSource<? extends T> source)
PushStream<T>
PushStream. merge(PushEventSource<? extends T> source)
Merge in the events from another source.Constructors in org.osgi.util.pushstream with parameters of type PushEventSource Constructor Description PushStreamBuilderImpl(PushStreamProvider psp, java.util.concurrent.Executor defaultExecutor, java.util.concurrent.ScheduledExecutorService defaultScheduler, PushEventSource<T> eventSource)
-