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

Classes in org.osgi.util.pushstream that implement PushEventConsumer

Modifier and Type	Class	Description
private static class	PushStreamProvider.MultiplexingConsumer<T>
(package private) static final class	PushStreamProvider.PushEventPipe<T>

Fields in org.osgi.util.pushstream declared as PushEventConsumer

Modifier and Type	Field	Description
(package private) PushEventConsumer<? super T>	PushStreamProvider.PushEventPipe.delegate

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

Modifier and Type	Field	Description
private final List<PushEventConsumer<? super T>>	SimplePushEventSourceImpl.connected
protected final Function<PushEventConsumer<T>,AutoCloseable>	UnbufferedPushStreamImpl.connector
private final CopyOnWriteArrayList<PushEventConsumer<? super T>>	PushStreamProvider.MultiplexingConsumer.consumers
protected final AtomicReference<PushEventConsumer<T>>	AbstractPushStreamImpl.next

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.
private void	SimplePushEventSourceImpl.closeConsumer(PushEventConsumer<? super T> pec, PushEvent<T> event)
<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.
private Promise<Long>	SimplePushEventSourceImpl.doCall(PushEvent<T> event, PushEventConsumer<? super T> pec)
private void	SimplePushEventSourceImpl.doSend(PushEventConsumer<? super T> pec, PushEvent<T> event)
private Promise<Long>	SimplePushEventSourceImpl.doSendWithBackPressure(PushEventConsumer<? super T> pec, PushEvent<T> event)
Promise<Long>	AbstractPushStreamImpl.forEachEvent(PushEventConsumer<? super T> action)
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.
AutoCloseable	PushStreamProvider.PushEventPipe.open(PushEventConsumer<? super T> pec)
AutoCloseable	SimplePushEventSourceImpl.open(PushEventConsumer<? super T> pec)
private long	SimplePushEventSourceImpl.safePush(PushEventConsumer<? super T> pec, PushEvent<T> event)
private void	AbstractPushStreamImpl.updateNext(PushEventConsumer<T> consumer)

Method parameters in org.osgi.util.pushstream with type arguments of type PushEventConsumer

Modifier and Type	Method	Description
private Promise<Long>	SimplePushEventSourceImpl.deliver(List<PushEventConsumer<? super T>> toCall, PushEvent<T> event)

Constructor parameters in org.osgi.util.pushstream with type arguments of type PushEventConsumer

Modifier	Constructor	Description
(package private)	BufferedPushStreamImpl(PushStreamProvider psp, PromiseFactory promiseFactory, U eventQueue, int parallelism, QueuePolicy<T,U> queuePolicy, PushbackPolicy<T,U> pushbackPolicy, Function<PushEventConsumer<T>,AutoCloseable> connector)
	MultiplexingConsumer(AtomicReference<PushEvent<T>> terminalEventStore, CopyOnWriteArrayList<PushEventConsumer<? super T>> consumers)
(package private)	UnbufferedPushStreamImpl(PushStreamProvider psp, PromiseFactory promiseFactory, Function<PushEventConsumer<T>,AutoCloseable> connector)