@Version("1.0")

Package org.osgi.util.pushstream

Push Stream Package Version 1.0.

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.0,2.0)"

Example import for providers implementing the API in this package:

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

Interface Summary

Interface	Description
BufferBuilder<R,T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>	Create a buffered section of a Push-based stream
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.
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 java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>	A Builder for a PushStream.
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.
SimplePushEventSource<T>	A SimplePushEventSource is a helper that makes it simpler to write a PushEventSource.

Class Summary

Class	Description
PushEvent<T>	A PushEvent is an immutable object that is transferred through a communication channel to push information to a downstream consumer.
PushStreamProvider	A factory for PushStream instances, and utility methods for handling PushEventSources and PushEventConsumers

Enum Summary

Enum	Description
PushbackPolicyOption	PushbackPolicyOption provides a standard set of simple PushbackPolicy implementations.
PushEvent.EventType	The type of a PushEvent.
QueuePolicyOption	QueuePolicyOption provides a standard set of simple QueuePolicy implementations.