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)"
ClassDescriptionCreate a buffered section of a Push-based streamA
PushbackPolicyis used to calculate how much back pressure to apply based on the current buffer.PushEvent<T>A PushEvent is an immutable object that is transferred through a communication channel to push information to a downstream consumer.The type of a
PushEvent.An Async Event Consumer asynchronously receives Data events until it receives either a Close or Error event.An event source.PushStream<T>A Push Stream fulfills the same role as the Java 8 stream but it reverses the control direction.A Builder for a PushStream.A
QueuePolicyis used to control how events should be queued in the current buffer.Provides a configurable
PushbackPolicyimplementation that returns zero back pressure until the buffer fills beyond the supplied threshold.