Package | Description |
---|---|
org.osgi.util.pushstream |
Push Stream Package Version 1.0.
|
Modifier and Type | Field and Description |
---|---|
protected PushbackPolicy<T,U> |
AbstractBufferBuilder.backPressure |
private PushbackPolicy<T,U> |
BufferedPushStreamImpl.pushbackPolicy |
Modifier and Type | Method and Description |
---|---|
abstract <T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>> |
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. |
Modifier and Type | Method and Description |
---|---|
(package private) <T,U extends java.util.concurrent.BlockingQueue<PushEvent<? extends 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) |
PushStreamBuilder<T,U> |
PushStreamBuilderImpl.withPushbackPolicy(PushbackPolicy<T,U> pushbackPolicy) |
PushStreamBuilder<T,U> |
PushStreamBuilder.withPushbackPolicy(PushbackPolicy<T,U> pushbackPolicy) |
BufferBuilder<R,T,U> |
BufferBuilder.withPushbackPolicy(PushbackPolicy<T,U> pushbackPolicy)
Set the
PushbackPolicy of this builder |
BufferBuilder<R,T,U> |
AbstractBufferBuilder.withPushbackPolicy(PushbackPolicy<T,U> pushbackPolicy) |
Constructor and 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) |