Uses of Class
org.osgi.util.pushstream.PushEvent
Packages that use PushEvent
-
Uses of PushEvent in org.osgi.util.pushstream
Classes in org.osgi.util.pushstream with type parameters of type PushEventModifier and TypeClassDescription(package private) class
AbstractBufferBuilder<R,
T, U extends BlockingQueue<PushEvent<? extends T>>> interface
BufferBuilder<R,
T, U extends BlockingQueue<PushEvent<? extends T>>> Create a buffered section of a Push-based stream(package private) class
BufferedPushStreamImpl<T,
U extends BlockingQueue<PushEvent<? extends T>>> interface
PushbackPolicy<T,
U extends BlockingQueue<PushEvent<? extends T>>> APushbackPolicy
is used to calculate how much back pressure to apply based on the current buffer.interface
PushStreamBuilder<T,
U extends BlockingQueue<PushEvent<? extends T>>> A Builder for a PushStream.(package private) class
PushStreamBuilderImpl<T,
U extends BlockingQueue<PushEvent<? extends T>>> interface
QueuePolicy<T,
U extends BlockingQueue<PushEvent<? extends T>>> AQueuePolicy
is used to control how events should be queued in the current buffer.(package private) class
SimplePushEventSourceImpl<T,
U extends BlockingQueue<PushEvent<? extends T>>> (package private) class
UnbufferedPushStreamImpl<T,
U extends BlockingQueue<PushEvent<? extends T>>> Subclasses of PushEvent in org.osgi.util.pushstreamModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
Fields in org.osgi.util.pushstream with type parameters of type PushEventModifier and TypeFieldDescriptionprivate final AtomicReference
<PushEvent<T>> PushStreamProvider.MultiplexingConsumer.terminalEventStore
Methods in org.osgi.util.pushstream with type parameters of type PushEventModifier and TypeMethodDescription<U extends BlockingQueue<PushEvent<? extends T>>>
PushStreamBuilder<T, U> AbstractPushStreamImpl.buildBuffer()
<U extends BlockingQueue<PushEvent<? extends T>>>
PushStreamBuilder<T, U> PushStream.buildBuffer()
Build a buffer to enqueue events in a queue using custom values for the queue size and other behaviors.<T,
U extends BlockingQueue<PushEvent<? extends T>>>
BufferBuilder<PushEventConsumer<T>, T, U> PushStreamProvider.buildBufferedConsumer
(PushEventConsumer<T> delegate) Build a bufferedPushEventConsumer
with custom configuration.<T,
U extends BlockingQueue<PushEvent<? extends T>>>
BufferBuilder<PushEventSource<T>, T, U> PushStreamProvider.buildEventSourceFromStream
(PushStream<T> stream) Convert anPushStream
into anPushEventSource
.<T,
U extends BlockingQueue<PushEvent<? extends T>>>
BufferBuilder<SimplePushEventSource<T>, T, U> PushStreamProvider.buildSimpleEventSource
(Class<T> type) Build aSimplePushEventSource
with the supplied type and custom buffering behaviors.<T,
U extends BlockingQueue<PushEvent<? extends T>>>
PushStreamBuilder<T, U> PushStreamProvider.buildStream
(PushEventSource<T> eventSource) Builds a push stream with custom configuration.(package private) <T,
U extends BlockingQueue<PushEvent<? extends T>>>
SimplePushEventSource<T> PushStreamProvider.createSimplePushEventSource
(int parallelism, Executor executor, U queue, QueuePolicy<T, U> queuePolicy, Runnable onClose) (package private) <T,
U extends BlockingQueue<PushEvent<? extends T>>>
PushStream<T> PushStreamProvider.createStream
(PushEventSource<T> eventSource, int parallelism, Executor executor, ScheduledExecutorService scheduler, U queue, QueuePolicy<T, U> queuePolicy, PushbackPolicy<T, U> pushbackPolicy) abstract <T,
U extends BlockingQueue<PushEvent<? extends T>>>
PushbackPolicy<T, U> PushbackPolicyOption.getPolicy
(long value) Create aPushbackPolicy
instance configured with a base back pressure time in nanoseconds The actual backpressure returned will vary based on the selected implementation, the base value, and the state of the buffer.abstract <T,
U extends BlockingQueue<PushEvent<? extends T>>>
QueuePolicy<T, U> QueuePolicyOption.getPolicy()
Methods in org.osgi.util.pushstream that return PushEventModifier and TypeMethodDescriptionstatic <T> PushEvent
<T> PushEvent.close()
Create a new close event.static <T> PushEvent
<T> PushEvent.data
(T payload) Create a new data event.static <T> PushEvent
<T> Create a new error event.<X> PushEvent
<X> PushEvent.DataEvent.nodata()
<X> PushEvent
<X> PushEvent.nodata()
Convenience to cast a close/error event to another payload type.Methods in org.osgi.util.pushstream with parameters of type PushEventModifier and TypeMethodDescriptionlong
Accept an event from a source.long
long
private <R> void
AbstractPushStreamImpl.aggregateAndForward
(BiFunction<Long, Collection<T>, R> f, AbstractPushStreamImpl<R> eventStream, PushEvent<? extends T> event, Queue<T> queue, Executor executor, long elapsed) private <R> long
AbstractPushStreamImpl.aggregateAndForward
(Function<Collection<T>, R> f, AbstractPushStreamImpl<R> eventStream, PushEvent<? extends T> event, Queue<T> queue) protected boolean
protected boolean
private void
protected boolean
private void
SimplePushEventSourceImpl.closeConsumer
(PushEventConsumer<? super T> pec, PushEvent<T> event) SimplePushEventSourceImpl.doCall
(PushEvent<T> event, PushEventConsumer<? super T> pec) void
Enqueue the event and return the remaining capacity available for eventsprivate void
SimplePushEventSourceImpl.doSend
(PushEventConsumer<? super T> pec, PushEvent<T> event) SimplePushEventSourceImpl.doSendWithBackPressure
(PushEventConsumer<? super T> pec, PushEvent<T> event) private void
SimplePushEventSourceImpl.enqueueEvent
(PushEvent<T> event) protected long
AbstractPushStreamImpl.handleEvent
(PushEvent<? extends T> event) protected long
BufferedPushStreamImpl.handleEvent
(PushEvent<? extends T> event) private long
SimplePushEventSourceImpl.safePush
(PushEventConsumer<? super T> pec, PushEvent<T> event) protected abstract void
AbstractPushStreamImpl.upstreamClose
(PushEvent<?> close) protected void
IntermediatePushStreamImpl.upstreamClose
(PushEvent<?> close) protected void
UnbufferedPushStreamImpl.upstreamClose
(PushEvent<?> close) Constructor parameters in org.osgi.util.pushstream with type arguments of type PushEventModifierConstructorDescriptionMultiplexingConsumer
(AtomicReference<PushEvent<T>> terminalEventStore, CopyOnWriteArrayList<PushEventConsumer<? super T>> consumers)