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 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 java.util.List<PushEventConsumer<? super T>>
SimplePushEventSourceImpl. connected
protected java.util.function.Function<PushEventConsumer<T>,java.lang.AutoCloseable>
UnbufferedPushStreamImpl. connector
private java.util.concurrent.CopyOnWriteArrayList<PushEventConsumer<? super T>>
PushStreamProvider.MultiplexingConsumer. consumers
protected java.util.concurrent.atomic.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 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.private void
SimplePushEventSourceImpl. closeConsumer(PushEventConsumer<? super T> pec, PushEvent<T> event)
<T> PushEventConsumer<T>
PushStreamProvider. createBufferedConsumer(PushEventConsumer<T> delegate)
Create a bufferedPushEventConsumer
with the default configured buffer, executor size, queue, queue policy and pushback policy.private Promise<java.lang.Long>
SimplePushEventSourceImpl. doCall(PushEvent<T> event, PushEventConsumer<? super T> pec)
private void
SimplePushEventSourceImpl. doSend(PushEventConsumer<? super T> pec, PushEvent<T> event)
private Promise<java.lang.Long>
SimplePushEventSourceImpl. doSendWithBackPressure(PushEventConsumer<? super T> pec, PushEvent<T> event)
Promise<java.lang.Long>
AbstractPushStreamImpl. forEachEvent(PushEventConsumer<? super T> action)
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.java.lang.AutoCloseable
PushStreamProvider.PushEventPipe. open(PushEventConsumer<? super T> pec)
java.lang.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<java.lang.Long>
SimplePushEventSourceImpl. deliver(java.util.List<PushEventConsumer<? super T>> toCall, PushEvent<T> event)
Constructor parameters in org.osgi.util.pushstream with type arguments of type PushEventConsumer Constructor Description BufferedPushStreamImpl(PushStreamProvider psp, PromiseFactory promiseFactory, U eventQueue, int parallelism, QueuePolicy<T,U> queuePolicy, PushbackPolicy<T,U> pushbackPolicy, java.util.function.Function<PushEventConsumer<T>,java.lang.AutoCloseable> connector)
MultiplexingConsumer(java.util.concurrent.atomic.AtomicReference<PushEvent<T>> terminalEventStore, java.util.concurrent.CopyOnWriteArrayList<PushEventConsumer<? super T>> consumers)
UnbufferedPushStreamImpl(PushStreamProvider psp, PromiseFactory promiseFactory, java.util.function.Function<PushEventConsumer<T>,java.lang.AutoCloseable> connector)
-