Package org.osgi.util.pushstream

@Version("1.1.0") package org.osgi.util.pushstream

Push Stream Package Version 1.1.

Bundles wishing to use this package must list the package in the Import-Package header of the bundle's manifest.

Example import for consumers using the API in this package:

Import-Package: org.osgi.util.pushstream; version="[1.1,2.0)"

Example import for providers implementing the API in this package:

Import-Package: org.osgi.util.pushstream; version="[1.1,1.2)"

Class	Description
BufferBuilder<R,T,U extends BlockingQueue<PushEvent<? extends T>>>	Create a buffered section of a Push-based stream
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.
PushbackPolicyOption	PushbackPolicyOption provides a standard set of simple PushbackPolicy implementations.
PushEvent<T>	A PushEvent is an immutable object that is transferred through a communication channel to push information to a downstream consumer.
PushEvent.EventType	The type of a PushEvent.
PushEventConsumer<T>	An Async Event Consumer asynchronously receives Data events until it receives either a Close or Error event.
PushEventSource<T>	An event source.
PushStream<T>	A Push Stream fulfills the same role as the Java 8 stream but it reverses the control direction.
PushStreamBuilder<T,U extends BlockingQueue<PushEvent<? extends T>>>	A Builder for a PushStream.
PushStreamProvider	A factory for PushStream instances, and utility methods for handling PushEventSources and PushEventConsumers
QueuePolicy<T,U extends BlockingQueue<PushEvent<? extends T>>>	A QueuePolicy is used to control how events should be queued in the current buffer.
QueuePolicyOption	QueuePolicyOption provides a standard set of simple QueuePolicy implementations.
SimplePushEventSource<T>	A SimplePushEventSource is a helper that makes it simpler to write a PushEventSource.
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.