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 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.

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

Modifier and Type	Method and 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.
abstract <T,U extends BlockingQueue<PushEvent<? extends T>>> QueuePolicy<T,U>	QueuePolicyOption.getPolicy()
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.

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(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