接口的使用
reactor.test.publisher.PublisherProbe

使用PublisherProbe的程序包

程序包	说明
reactor.test.publisher	Components supporting the creation of test-oriented Publishers.

reactor.test.publisher中PublisherProbe的使用

实现PublisherProbe的reactor.test.publisher中的类

限定符和类型	类和说明
static class	PublisherProbe.DefaultPublisherProbe<T>
class	TestPublisher<T> A Publisher that you can directly manipulate, triggering onNext, onComplete and onError events, for testing purposes.

返回PublisherProbe的reactor.test.publisher中的方法

限定符和类型	方法和说明
static <T> PublisherProbe<T>	PublisherProbe.empty() Create a PublisherProbe of which flux() and mono() versions will simply complete, capturing subscription, cancellation and request events around them.
static <T> PublisherProbe<T>	PublisherProbe.of(org.reactivestreams.Publisher<? extends T> source) Create a PublisherProbe out of a Publisher, ensuring that its flux() and mono() versions will propagate signals from this publisher while capturing subscription, cancellation and request events around it.