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 PushbackPolicy<T,U>
BufferedPushStreamImpl. pushbackPolicy
Methods in org.osgi.util.pushstream that return PushbackPolicy Modifier and Type Method Description abstract <T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
PushbackPolicy<T,U>PushbackPolicyOption. getPolicy(long value)
Create aPushbackPolicy
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 java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>
PushStream<T>PushStreamProvider. createStream(PushEventSource<T> eventSource, int parallelism, java.util.concurrent.Executor executor, java.util.concurrent.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 thePushbackPolicy
of this builderPushStreamBuilder<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 Constructor Description BufferedPushStreamImpl(PushStreamProvider psp, PromiseFactory promiseFactory, U eventQueue, int parallelism, QueuePolicy<T,U> queuePolicy, PushbackPolicy<T,U> pushbackPolicy, java.util.function.Function<PushEventConsumer<T>,java.lang.AutoCloseable> connector)
-