Uses of Interface
org.osgi.util.pushstream.PushEventConsumer
Packages that use PushEventConsumer
-
Uses of PushEventConsumer in org.osgi.util.pushstream
Classes in org.osgi.util.pushstream that implement PushEventConsumerModifier and TypeClassDescriptionprivate static class
(package private) static final class
Fields in org.osgi.util.pushstream declared as PushEventConsumerModifier and TypeFieldDescription(package private) PushEventConsumer<? super T>
PushStreamProvider.PushEventPipe.delegate
Fields in org.osgi.util.pushstream with type parameters of type PushEventConsumerModifier and TypeFieldDescriptionprivate 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 PushEventConsumerModifier and TypeMethodDescription<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 PushEventConsumerModifier and TypeMethodDescription<T,
U extends 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 PushEventConsumerModifier and TypeMethodDescription<T,
U extends 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.SimplePushEventSourceImpl.doCall
(PushEvent<T> event, PushEventConsumer<? super T> pec) private void
SimplePushEventSourceImpl.doSend
(PushEventConsumer<? super T> pec, PushEvent<T> event) SimplePushEventSourceImpl.doSendWithBackPressure
(PushEventConsumer<? super T> pec, PushEvent<T> event) AbstractPushStreamImpl.forEachEvent
(PushEventConsumer<? super T> action) PushStream.forEachEvent
(PushEventConsumer<? super T> action) Pass on each event to another consumer until the stream is closed.PushEventSource.open
(PushEventConsumer<? super T> aec) Open the asynchronous channel between the source and the consumer.PushStreamProvider.PushEventPipe.open
(PushEventConsumer<? super T> pec) 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 PushEventConsumerModifier and TypeMethodDescriptionConstructor parameters in org.osgi.util.pushstream with type arguments of type PushEventConsumerModifierConstructorDescription(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)