Uses of Interface
org.osgi.util.pushstream.PushbackPolicy

Packages that use PushbackPolicy

Package	Description
org.osgi.util.pushstream	Push Stream Package Version 1.1.

Uses of PushbackPolicy in org.osgi.util.pushstream

Classes in org.osgi.util.pushstream that implement PushbackPolicy

Modifier and Type	Class	Description
final class	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.

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

Modifier and Type	Method	Description
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 with parameters of type PushbackPolicy

Modifier and Type	Method	Description
BufferBuilder<R,T,U>	BufferBuilder.withPushbackPolicy(PushbackPolicy<T,U> pushbackPolicy)	Set the PushbackPolicy of this builder
PushStreamBuilder<T,U>	PushStreamBuilder.withPushbackPolicy(PushbackPolicy<T,U> pushbackPolicy)