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 TypeInterfaceDescriptioninterface
BufferBuilder<R,
T, U extends BlockingQueue<PushEvent<? extends T>>> Create a buffered section of a Push-based streaminterface
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.interface
QueuePolicy<T,
U extends 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 PushEventModifier and TypeMethodDescription<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.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.nodata()
Convenience to cast a close/error event to another payload type.Methods in org.osgi.util.pushstream with parameters of type PushEvent