Uses of Class
org.osgi.util.pushstream.PushEvent
-
Uses of PushEvent in org.osgi.util.pushstream
Modifier 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.final class
ThresholdPushbackPolicy<T,
U extends BlockingQueue<PushEvent<? extends T>>> Provides a configurablePushbackPolicy
implementation that returns zero back pressure until the buffer fills beyond the supplied threshold.Modifier 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.static <T,
U extends BlockingQueue<PushEvent<? extends T>>>
ThresholdPushbackPolicy<T,U> ThresholdPushbackPolicy.createIncrementalThresholdPushbackPolicy
(int threshold, long increment) A simple configuration, where the increment size is used as the initial back pressure.static <T,
U extends BlockingQueue<PushEvent<? extends T>>>
ThresholdPushbackPolicy<T,U> ThresholdPushbackPolicy.createSimpleThresholdPushbackPolicy
(int threshold) A simple configuration with an initial back pressure of one and and increase increment size of one.static <T,
U extends BlockingQueue<PushEvent<? extends T>>>
ThresholdPushbackPolicy<T,U> ThresholdPushbackPolicy.createThresholdPushbackPolicy
(int threshold, long initial, long increment) Provides aThresholdPushbackPolicy
with an individual configuration for all possible parameters.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()
Modifier 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.