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 and Description
interface	BufferBuilder<R,T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> Create a buffered section of a Push-based stream
interface	PushbackPolicy<T,U extends java.util.concurrent.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 java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> A Builder for a PushStream.
interface	QueuePolicy<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> A QueuePolicy 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 and 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 buffered PushEventConsumer with custom configuration.
<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> BufferBuilder<PushEventSource<T>,T,U>	PushStreamProvider.buildEventSourceFromStream(PushStream<T> stream) Convert an PushStream into an PushEventSource.
<T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> BufferBuilder<SimplePushEventSource<T>,T,U>	PushStreamProvider.buildSimpleEventSource(java.lang.Class<T> type) Build a SimplePushEventSource 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>>> QueuePolicy<T,U>	QueuePolicyOption.getPolicy()
abstract <T,U extends java.util.concurrent.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.

Methods in org.osgi.util.pushstream that return PushEvent

Modifier and Type	Method and 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 and 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