Package | Description |
---|---|
org.osgi.util.pushstream |
Push Stream Package Version 1.0.
|
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 |
---|---|
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 |
Copyright © OSGi Alliance (2000, 2018). All Rights Reserved. Licensed under the OSGi Specification License, Version 2.0