类的使用
reactor.test.subscriber.AssertSubscriber

使用AssertSubscriber的程序包

程序包	说明
reactor.test.subscriber	Components supporting the creation of test-oriented Subscribers.

reactor.test.subscriber中AssertSubscriber的使用

返回AssertSubscriber的reactor.test.subscriber中的方法

限定符和类型	方法和说明
AssertSubscriber<T>	AssertSubscriber.assertComplete() Assert a complete successfully signal has been received.
AssertSubscriber<T>	AssertSubscriber.assertContainValues(java.util.Set<? extends T> expectedValues) Assert the specified values have been received.
AssertSubscriber<T>	AssertSubscriber.assertError() Assert an error signal has been received.
AssertSubscriber<T>	AssertSubscriber.assertError(java.lang.Class<? extends java.lang.Throwable> clazz) Assert an error signal has been received.
AssertSubscriber<T>	AssertSubscriber.assertErrorMessage(java.lang.String message)
AssertSubscriber<T>	AssertSubscriber.assertErrorWith(java.util.function.Consumer<? super java.lang.Throwable> expectation) Assert an error signal has been received.
AssertSubscriber<T>	AssertSubscriber.assertFuseableSource() Assert that the upstream was a Fuseable source.
AssertSubscriber<T>	AssertSubscriber.assertFusionEnabled() Assert that the fusion mode was granted.
AssertSubscriber<T>	AssertSubscriber.assertFusionMode(int expectedMode)
AssertSubscriber<T>	AssertSubscriber.assertFusionRejected() Assert that the fusion mode was granted.
AssertSubscriber<T>	AssertSubscriber.assertIncomplete(T... values)
AssertSubscriber<T>	AssertSubscriber.assertNoError() Assert no error signal has been received.
AssertSubscriber<T>	AssertSubscriber.assertNoEvents()
AssertSubscriber<T>	AssertSubscriber.assertNonFuseableSource() Assert that the upstream was not a Fuseable source.
AssertSubscriber<T>	AssertSubscriber.assertNotComplete() Assert no complete successfully signal has been received.
AssertSubscriber<T>	AssertSubscriber.assertNotSubscribed() Assert no subscription occurred.
AssertSubscriber<T>	AssertSubscriber.assertNotTerminated() Assert no complete successfully or error signal has been received.
AssertSubscriber<T>	AssertSubscriber.assertNoValues() Assert no values have been received.
AssertSubscriber<T>	AssertSubscriber.assertSubscribed() Assert subscription occurred (once).
AssertSubscriber<T>	AssertSubscriber.assertTerminated() Assert either complete successfully or error signal has been received.
AssertSubscriber<T>	AssertSubscriber.assertValueCount(long n) Assert n values has been received.
AssertSubscriber<T>	AssertSubscriber.assertValues(T... expectedValues) Assert the specified values have been received in the declared order.
AssertSubscriber<T>	AssertSubscriber.assertValueSequence(java.lang.Iterable<? extends T> expectedSequence) Assert the specified values have been received in the same order read by the passed Iterable.
AssertSubscriber<T>	AssertSubscriber.assertValuesWith(java.util.function.Consumer<T>... expectations) Assert the specified values have been received in the declared order.
AssertSubscriber<T>	AssertSubscriber.await() Blocking method that waits until a complete successfully or error signal is received.
AssertSubscriber<T>	AssertSubscriber.await(java.time.Duration timeout) Blocking method that waits until a complete successfully or error signal is received or until a timeout occurs.
AssertSubscriber<T>	AssertSubscriber.awaitAndAssertNextValueCount(long n) Blocking method that waits until n next values have been received.
AssertSubscriber<T>	AssertSubscriber.awaitAndAssertNextValues(T... values) Blocking method that waits until n next values have been received (n is the number of values provided) to assert them.
AssertSubscriber<T>	AssertSubscriber.awaitAndAssertNextValuesWith(java.util.function.Consumer<T>... expectations) Blocking method that waits until n next values have been received (n is the number of expectations provided) to assert them.
AssertSubscriber<T>	AssertSubscriber.configureValuesStorage(boolean enabled) Enable or disabled the values storage.
AssertSubscriber<T>	AssertSubscriber.configureValuesTimeout(java.time.Duration timeout) Configure the timeout in seconds for waiting next values to be received (3 seconds by default).
static <T> AssertSubscriber<T>	AssertSubscriber.create() Create a new AssertSubscriber that requests an unbounded number of elements.
static <T> AssertSubscriber<T>	AssertSubscriber.create(long n) Create a new AssertSubscriber that requests initially n elements.
AssertSubscriber<T>	AssertSubscriber.requestedFusionMode(int requestMode) Setup what fusion mode should be requested from the incoming Subscription if it happens to be QueueSubscription