Uses of Interface
org.osgi.util.pushstream.PushEventConsumer

Packages that use PushEventConsumer

Package	Description
org.osgi.util.pushstream	Push Stream Package Version 1.1.

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 buffered PushEventConsumer 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 BlockingQueue<PushEvent<? extends T>>> BufferBuilder<PushEventConsumer<T>,T,U>	PushStreamProvider.buildBufferedConsumer(PushEventConsumer<T> delegate)	Build a buffered PushEventConsumer with custom configuration.

Methods in org.osgi.util.pushstream with parameters of type PushEventConsumer

Modifier and Type	Method	Description
<T, U extends BlockingQueue<PushEvent<? extends T>>> BufferBuilder<PushEventConsumer<T>,T,U>	PushStreamProvider.buildBufferedConsumer(PushEventConsumer<T> delegate)	Build a buffered PushEventConsumer with custom configuration.
<T> PushEventConsumer<T>	PushStreamProvider.createBufferedConsumer(PushEventConsumer<T> delegate)	Create a buffered PushEventConsumer with the default configured buffer, executor size, queue, queue policy and pushback policy.
Promise<Long>	PushStream.forEachEvent(PushEventConsumer<? super T> action)	Pass on each event to another consumer until the stream is closed.
AutoCloseable	PushEventSource.open(PushEventConsumer<? super T> aec)	Open the asynchronous channel between the source and the consumer.