Uses of Class
org.osgi.util.pushstream.PushEvent
-
Packages that use PushEvent Package Description org.osgi.util.pushstream Push Stream Package Version 1.0. -
-
Uses of PushEvent in org.osgi.util.pushstream
Classes in org.osgi.util.pushstream with type parameters of type PushEvent Modifier and Type Class Description (package private) class
AbstractBufferBuilder<R,T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
interface
BufferBuilder<R,T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
Create a buffered section of a Push-based stream(package private) class
BufferedPushStreamImpl<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
interface
PushbackPolicy<T,U extends java.util.concurrent.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 java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
A Builder for a PushStream.(package private) class
PushStreamBuilderImpl<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
interface
QueuePolicy<T,U extends java.util.concurrent.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 java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
(package private) class
UnbufferedPushStreamImpl<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
Subclasses of PushEvent in org.osgi.util.pushstream Modifier and Type Class Description (package private) static class
PushEvent.CloseEvent<T>
(package private) static class
PushEvent.DataEvent<T>
(package private) static class
PushEvent.ErrorEvent<T>
Fields in org.osgi.util.pushstream with type parameters of type PushEvent Modifier and Type Field Description private java.util.concurrent.atomic.AtomicReference<PushEvent<T>>
PushStreamProvider.MultiplexingConsumer. terminalEventStore
Methods in org.osgi.util.pushstream with type parameters of type PushEvent Modifier and Type Method Description <U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
PushStreamBuilder<T,U>AbstractPushStreamImpl. buildBuffer()
<U extends java.util.concurrent.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 java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
BufferBuilder<PushEventConsumer<T>,T,U>PushStreamProvider. buildBufferedConsumer(PushEventConsumer<T> delegate)
Build a bufferedPushEventConsumer
with custom configuration.<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
BufferBuilder<PushEventSource<T>,T,U>PushStreamProvider. buildEventSourceFromStream(PushStream<T> stream)
Convert anPushStream
into anPushEventSource
.<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
BufferBuilder<SimplePushEventSource<T>,T,U>PushStreamProvider. buildSimpleEventSource(java.lang.Class<T> type)
Build aSimplePushEventSource
with the supplied type and custom buffering behaviors.<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
PushStreamBuilder<T,U>PushStreamProvider. buildStream(PushEventSource<T> eventSource)
Builds a push stream with custom configuration.(package private) <T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
SimplePushEventSource<T>PushStreamProvider. createSimplePushEventSource(int parallelism, java.util.concurrent.Executor executor, U queue, QueuePolicy<T,U> queuePolicy, java.lang.Runnable onClose)
(package private) <T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
PushStream<T>PushStreamProvider. createStream(PushEventSource<T> eventSource, int parallelism, java.util.concurrent.Executor executor, java.util.concurrent.ScheduledExecutorService scheduler, U queue, QueuePolicy<T,U> queuePolicy, PushbackPolicy<T,U> pushbackPolicy)
abstract <T,U extends java.util.concurrent.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 java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
QueuePolicy<T,U>QueuePolicyOption. getPolicy()
Methods in org.osgi.util.pushstream that return PushEvent Modifier and Type Method Description static <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>
PushEvent. error(java.lang.Throwable 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 PushEvent Modifier and Type Method Description long
PushEventConsumer. accept(PushEvent<? extends T> event)
Accept an event from a source.long
PushStreamProvider.MultiplexingConsumer. accept(PushEvent<? extends T> event)
long
PushStreamProvider.PushEventPipe. accept(PushEvent<? extends T> event)
private <R> void
AbstractPushStreamImpl. aggregateAndForward(java.util.function.BiFunction<java.lang.Long,java.util.Collection<T>,R> f, AbstractPushStreamImpl<R> eventStream, PushEvent<? extends T> event, java.util.Queue<T> queue, java.util.concurrent.Executor executor, long elapsed)
private <R> long
AbstractPushStreamImpl. aggregateAndForward(Function<java.util.Collection<T>,R> f, AbstractPushStreamImpl<R> eventStream, PushEvent<? extends T> event, java.util.Queue<T> queue)
protected boolean
AbstractPushStreamImpl. close(PushEvent<T> event)
protected boolean
AbstractPushStreamImpl. close(PushEvent<T> event, boolean sendDownStreamEvent)
private void
SimplePushEventSourceImpl. close(PushEvent<T> event)
protected boolean
UnbufferedPushStreamImpl. close(PushEvent<T> event, boolean sendDownStreamEvent)
private void
SimplePushEventSourceImpl. closeConsumer(PushEventConsumer<? super T> pec, PushEvent<T> event)
private Promise<java.lang.Long>
SimplePushEventSourceImpl. deliver(java.util.List<PushEventConsumer<? super T>> toCall, PushEvent<T> event)
private Promise<java.lang.Long>
SimplePushEventSourceImpl. doCall(PushEvent<T> event, PushEventConsumer<? super T> pec)
void
QueuePolicy. doOffer(U queue, PushEvent<? extends T> event)
Enqueue the event and return the remaining capacity available for eventsprivate void
SimplePushEventSourceImpl. doSend(PushEventConsumer<? super T> pec, PushEvent<T> event)
private Promise<java.lang.Long>
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 PushEvent Constructor Description MultiplexingConsumer(java.util.concurrent.atomic.AtomicReference<PushEvent<T>> terminalEventStore, java.util.concurrent.CopyOnWriteArrayList<PushEventConsumer<? super T>> consumers)
-