Uses of Class
org.osgi.util.pushstream.PushEvent

Packages that use PushEvent

Package	Description
org.osgi.util.pushstream	Push Stream Package Version 1.1.

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 BlockingQueue<PushEvent<? extends T>>>	Create a buffered section of a Push-based stream
interface	PushbackPolicy<T,U extends BlockingQueue<PushEvent<? extends T>>>	A PushbackPolicy 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>>>	A QueuePolicy 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 configurable PushbackPolicy implementation that returns zero back pressure until the buffer fills beyond the supplied threshold.

Methods in org.osgi.util.pushstream with type parameters of type PushEvent

Modifier and Type	Method	Description
<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 buffered PushEventConsumer with custom configuration.
<T, U extends BlockingQueue<PushEvent<? extends T>>> BufferBuilder<PushEventSource<T>,T,U>	PushStreamProvider.buildEventSourceFromStream(PushStream<T> stream)	Convert an PushStream into an PushEventSource.
<T, U extends BlockingQueue<PushEvent<? extends T>>> BufferBuilder<SimplePushEventSource<T>,T,U>	PushStreamProvider.buildSimpleEventSource(Class<T> type)	Build a SimplePushEventSource 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 a ThresholdPushbackPolicy with an individual configuration for all possible parameters.
abstract <T, U extends BlockingQueue<PushEvent<? extends T>>> PushbackPolicy<T,U>	PushbackPolicyOption.getPolicy(long value)	Create a PushbackPolicy 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 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(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