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

Packages that use PushbackPolicy

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

Uses of PushbackPolicy in org.osgi.util.pushstream

Fields in org.osgi.util.pushstream declared as PushbackPolicy

Modifier and Type	Field	Description
protected PushbackPolicy<T,U>	AbstractBufferBuilder.backPressure
private final PushbackPolicy<T,U>	BufferedPushStreamImpl.pushbackPolicy

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
(package private) <T, U extends BlockingQueue<PushEvent<? extends T>>> PushStream<T>	PushStreamProvider.createStream(PushEventSource<T> eventSource, int parallelism, Executor executor, ScheduledExecutorService scheduler, U queue, QueuePolicy<T,U> queuePolicy, PushbackPolicy<T,U> pushbackPolicy)
BufferBuilder<R,T,U>	AbstractBufferBuilder.withPushbackPolicy(PushbackPolicy<T,U> pushbackPolicy)
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)
PushStreamBuilder<T,U>	PushStreamBuilderImpl.withPushbackPolicy(PushbackPolicy<T,U> pushbackPolicy)

Constructors in org.osgi.util.pushstream with parameters of type PushbackPolicy

Modifier	Constructor	Description
(package private)	BufferedPushStreamImpl(PushStreamProvider psp, PromiseFactory promiseFactory, U eventQueue, int parallelism, QueuePolicy<T,U> queuePolicy, PushbackPolicy<T,U> pushbackPolicy, Function<PushEventConsumer<T>,AutoCloseable> connector)