接口的使用
reactor.core.CorePublisher

使用CorePublisher的程序包

程序包	说明
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.test	Main test components supporting the testing and assertion of publishers.

reactor.core.publisher中CorePublisher的使用

实现CorePublisher的reactor.core.publisher中的类

限定符和类型	类和说明
class	ConnectableFlux<T> The abstract base class for connectable publishers that let subscribers pile up before they connect to their data source.
class	DirectProcessor<T> 已过时。 To be removed in 3.5, prefer clear cut usage of Sinks. Closest sink is Sinks.many().multicast().directBestEffort(), except it doesn't terminate overflowing downstreams.
class	EmitterProcessor<T> 已过时。 To be removed in 3.5. Prefer clear cut usage of Sinks through variations of Sinks.many().multicast().onBackpressureBuffer(). If you really need the subscribe-to-upstream functionality of a Processor, switch to Sinks.ManyWithUpstream with Sinks.unsafe() variants of Sinks.unsafe().manyWithUpstream(). This processor was blocking in EmitterProcessor.onNext(Object). This behaviour can be implemented with the Sinks API by calling Sinks.Many.tryEmitNext(Object) and retrying, e.g.: while (sink.tryEmitNext(v).hasFailed()) { LockSupport.parkNanos(10); }
class	Flux<T> A Reactive Streams Publisher with rx operators that emits 0 to N elements, and then completes (successfully or with an error).
class	FluxOperator<I,O> A decorating Flux Publisher that exposes Flux API over an arbitrary Publisher.
class	FluxProcessor<IN,OUT> 已过时。 Processors will be removed in 3.5. Prefer using Sinks.Many instead, or see https://github.com/reactor/reactor-core/issues/2431 for alternatives
class	GroupedFlux<K,V> Represents a sequence of events which has an associated key.
class	Mono<T> A Reactive Streams Publisher with basic rx operators that emits at most one item via the onNext signal then terminates with an onComplete signal (successful Mono, with or without value), or only emits a single onError signal (failed Mono).
class	MonoOperator<I,O> A decorating Mono Publisher that exposes Mono API over an arbitrary Publisher Useful to create operators which return a Mono.
class	MonoProcessor<O> 已过时。 Processors will be removed in 3.5. Prefer using Sinks.One or Sinks.Empty instead, or see https://github.com/reactor/reactor-core/issues/2431 for alternatives
class	ParallelFlux<T> A ParallelFlux publishes to an array of Subscribers, in parallel 'rails' (or 'groups').
class	ReplayProcessor<T> 已过时。 To be removed in 3.5, prefer clear cut usage of Sinks through variations under Sinks.many().replay().
class	UnicastProcessor<T> 已过时。 to be removed in 3.5, prefer clear cut usage of Sinks through variations under Sinks.many().unicast().

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

限定符和类型	方法和说明
static <T> CorePublisher<T>	Operators.onLastAssembly(CorePublisher<T> source) Applies the hooks registered with Hooks.onLastOperator(java.util.function.Function<? super org.reactivestreams.Publisher<java.lang.Object>, ? extends org.reactivestreams.Publisher<java.lang.Object>>) and returns CorePublisher ready to be subscribed on.

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

限定符和类型	方法和说明
static <T> CorePublisher<T>	Operators.onLastAssembly(CorePublisher<T> source) Applies the hooks registered with Hooks.onLastOperator(java.util.function.Function<? super org.reactivestreams.Publisher<java.lang.Object>, ? extends org.reactivestreams.Publisher<java.lang.Object>>) and returns CorePublisher ready to be subscribed on.

reactor.test中CorePublisher的使用

实现CorePublisher的reactor.test中的类

限定符和类型	类和说明
static class	MockUtils.TestScannableConnectableFlux<T> An abstract class that can be used to mock a Scannable ConnectableFlux.