Package | Description |
---|---|
org.osgi.util.pushstream |
Push Stream Package Version 1.0.
|
Modifier and Type | Method and Description |
---|---|
abstract <T,U extends 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 © Contributors to the Eclipse Foundation Licensed under the Eclipse Foundation Specification License – v1.0