类的使用
reactor.test.publisher.TestPublisher

使用TestPublisher的程序包

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

reactor.test.publisher中TestPublisher的使用

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

限定符和类型	方法和说明
abstract TestPublisher<T>	TestPublisher.assertCancelled() Asserts that this publisher has had at least one subscriber that has been cancelled.
abstract TestPublisher<T>	TestPublisher.assertCancelled(int n) Asserts that this publisher has had at least n subscribers that have been cancelled.
abstract TestPublisher<T>	TestPublisher.assertMaxRequested(long n) Assert that the current maximum request of all this publisher's subscribers is <= n.
abstract TestPublisher<T>	TestPublisher.assertMinRequested(long n) Assert that the current minimum request of all this publisher's subscribers is >= n.
abstract TestPublisher<T>	TestPublisher.assertNoRequestOverflow() Asserts that this publisher has had no subscriber with request overflow.
abstract TestPublisher<T>	TestPublisher.assertNoSubscribers() Asserts that this publisher has no subscribers.
abstract TestPublisher<T>	TestPublisher.assertNotCancelled() Asserts that this publisher has had no cancelled subscribers.
abstract TestPublisher<T>	TestPublisher.assertRequestOverflow() Asserts that this publisher has had subscriber that saw request overflow, that is received an onNext event despite having a requested amount of 0 at the time.
abstract TestPublisher<T>	TestPublisher.assertSubscribers() Asserts that this publisher has subscribers.
abstract TestPublisher<T>	TestPublisher.assertSubscribers(int n) Asserts that this publisher has exactly n subscribers.
abstract TestPublisher<T>	TestPublisher.complete() Triggers completion of this publisher.
static <T> TestPublisher<T>	TestPublisher.create() Create a standard hot TestPublisher.
static <T> TestPublisher<T>	TestPublisher.createCold() Create a cold TestPublisher, which can be subscribed to by multiple subscribers.
static <T> TestPublisher<T>	TestPublisher.createColdNonBuffering() Create a cold TestPublisher, which can be subscribed to by multiple subscribers.
static <T> TestPublisher<T>	TestPublisher.createColdNonCompliant(boolean errorOnOverflow, TestPublisher.Violation firstViolation, TestPublisher.Violation... otherViolations) Create a cold TestPublisher, which can be subscribed to by multiple subscribers.
static <T> TestPublisher<T>	TestPublisher.createNoncompliant(TestPublisher.Violation first, TestPublisher.Violation... rest) Create a noncompliant hot TestPublisher with a given set of reactive streams spec violations that will be overlooked.
TestPublisher<T>	TestPublisher.emit(T... values) Combine emitting items and completing this publisher.
abstract TestPublisher<T>	TestPublisher.error(java.lang.Throwable t) Triggers an error signal to the subscribers.
abstract TestPublisher<T>	TestPublisher.next(T value) Send 1 onNext signal to the subscribers.
TestPublisher<T>	TestPublisher.next(T first, T... rest) Send 1-n onNext signals to the subscribers.