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 Interface Description interface
BufferBuilder<R,T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
Create a buffered section of a Push-based streaminterface
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.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.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>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.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. 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.void
QueuePolicy. doOffer(U queue, PushEvent<? extends T> event)
Enqueue the event and return the remaining capacity available for events
-