接口的使用
reactor.core.publisher.FluxSink

使用FluxSink的程序包

程序包	说明
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的使用

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

限定符和类型	方法和说明
FluxSink<T>	FluxSink.next(T t) Emit a non-null element, generating an onNext signal.
FluxSink<T>	FluxSink.onCancel(Disposable d) Attach a Disposable as a callback for when this FluxSink is cancelled.
FluxSink<T>	FluxSink.onDispose(Disposable d) Attach a Disposable as a callback for when this FluxSink is effectively disposed, that is it cannot be used anymore.
FluxSink<T>	FluxSink.onRequest(java.util.function.LongConsumer consumer) Attaches a LongConsumer to this FluxSink that will be notified of any request to this sink.
FluxSink<IN>	FluxProcessor.sink() 已过时。 To be removed in 3.5, prefer clear cut usage of Sinks through the Sinks.many() spec.
FluxSink<IN>	FluxProcessor.sink(FluxSink.OverflowStrategy strategy) 已过时。 To be removed in 3.5, prefer clear cut usage of Sinks through the Sinks.many() spec.

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

限定符和类型	方法和说明
static <T> Flux<T>	Flux.create(java.util.function.Consumer<? super FluxSink<T>> emitter) 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.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) Programmatically create a Flux with the capability of emitting multiple elements from a single-threaded producer 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.