程序包 | 说明 |
---|---|
reactor.core.publisher |
限定符和类型 | 方法和说明 |
---|---|
static BufferOverflowStrategy |
BufferOverflowStrategy.valueOf(java.lang.String name)
返回带有指定名称的该类型的枚举常量。
|
static BufferOverflowStrategy[] |
BufferOverflowStrategy.values()
按照声明该枚举类型的常量的顺序, 返回
包含这些常量的数组。
|
限定符和类型 | 方法和说明 |
---|---|
Flux<T> |
Flux.onBackpressureBuffer(int maxSize,
BufferOverflowStrategy bufferOverflowStrategy)
Request an unbounded demand and push to the returned
Flux , or park the observed
elements if not enough demand is requested downstream, within a maxSize
limit. |
Flux<T> |
Flux.onBackpressureBuffer(int maxSize,
java.util.function.Consumer<? super T> onBufferOverflow,
BufferOverflowStrategy bufferOverflowStrategy)
Request an unbounded demand and push to the returned
Flux , or park the observed
elements if not enough demand is requested downstream, within a maxSize
limit. |