类的使用
reactor.core.publisher.FluxSink.OverflowStrategy

使用FluxSink.OverflowStrategy的程序包

程序包	说明
reactor.core.publisher	Provide main Reactive APIs in Flux and Mono, as well as various helper classes, interfaces used in the composition API, variants of Flux and operator-building utilities.

reactor.core.publisher中FluxSink.OverflowStrategy的使用

返回FluxSink.OverflowStrategy的reactor.core.publisher中的方法

限定符和类型	方法和说明
static FluxSink.OverflowStrategy	FluxSink.OverflowStrategy.valueOf(java.lang.String name) 返回带有指定名称的该类型的枚举常量。
static FluxSink.OverflowStrategy[]	FluxSink.OverflowStrategy.values() 按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

参数类型为FluxSink.OverflowStrategy的reactor.core.publisher中的方法

限定符和类型	方法和说明
static <T> Flux<T>	Flux.create(java.util.function.Consumer<? super FluxSink<T>> emitter, FluxSink.OverflowStrategy backpressure) Programmatically create a Flux with the capability of emitting multiple elements in a synchronous or asynchronous manner through the FluxSink API.
static <T> Flux<T>	Flux.push(java.util.function.Consumer<? super FluxSink<T>> emitter, FluxSink.OverflowStrategy backpressure) Programmatically create a Flux with the capability of emitting multiple elements from a single-threaded producer through the FluxSink API.
FluxSink<IN>	FluxProcessor.sink(FluxSink.OverflowStrategy strategy) 已过时。 To be removed in 3.5, prefer clear cut usage of Sinks through the Sinks.many() spec.