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 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 java.util.concurrent.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 java.util.concurrent.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<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.