Uses of Interface
org.osgi.util.pushstream.PushEventConsumer
-
Packages that use PushEventConsumer Package Description org.osgi.util.pushstream Push Stream Package Version 1.0. -
-
Uses of PushEventConsumer in org.osgi.util.pushstream
Methods in org.osgi.util.pushstream that return PushEventConsumer Modifier and Type Method Description <T> PushEventConsumer<T>
PushStreamProvider. createBufferedConsumer(PushEventConsumer<T> delegate)
Create a bufferedPushEventConsumer
with the default configured buffer, executor size, queue, queue policy and pushback policy.Methods in org.osgi.util.pushstream that return types with arguments of type PushEventConsumer Modifier and Type Method Description <T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
BufferBuilder<PushEventConsumer<T>,T,U>PushStreamProvider. buildBufferedConsumer(PushEventConsumer<T> delegate)
Build a bufferedPushEventConsumer
with custom configuration.Methods in org.osgi.util.pushstream with parameters of type PushEventConsumer Modifier and Type Method Description <T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
BufferBuilder<PushEventConsumer<T>,T,U>PushStreamProvider. buildBufferedConsumer(PushEventConsumer<T> delegate)
Build a bufferedPushEventConsumer
with custom configuration.<T> PushEventConsumer<T>
PushStreamProvider. createBufferedConsumer(PushEventConsumer<T> delegate)
Create a bufferedPushEventConsumer
with the default configured buffer, executor size, queue, queue policy and pushback policy.Promise<java.lang.Long>
PushStream. forEachEvent(PushEventConsumer<? super T> action)
Pass on each event to another consumer until the stream is closed.java.lang.AutoCloseable
PushEventSource. open(PushEventConsumer<? super T> aec)
Open the asynchronous channel between the source and the consumer.
-