reactor.test

类 StepVerifierTests

java.lang.Object

reactor.test.StepVerifierTests

public class StepVerifierTests
extends java.lang.Object

作者:

Arjen Poutsma, Sebastien Deleuze, Stephane Maldini, Simon Basle

构造器概要

构造器

构造器和说明
StepVerifierTests()

方法概要

限定符和类型	方法和说明
void	assertNextLowRequestShortcircuits()
void	assertNextWithSubscribeOnJust()
void	assertNextWithSubscribeOnSink()
void	boundedInitialOverflowIsDetected()
void	boundedRequestOverflowIsDetected()
void	cancel()
void	cancelAsyncFusion()
void	cancelInvalid()
void	cancelOnUnexpectedNextWithMoreData()
void	consumeErrorWith()
void	consumeNextErrorIsSuppressed()
void	consumeNextWith()
void	consumeNextWith2()
void	consumeNextWithLowRequestShortcircuits()
void	consumeWhileErrorIsSuppressed()
void	error()
void	errorClass()
void	errorMatches()
void	errorMatchesInvalid()
void	errorMessage()
void	errorSatisfies()
void	expectationErrorWithGenericValueFormatterBypassesExtractor()
void	expectationErrorWithoutValueFormatter()
void	expectationErrorWithSpecificValueFormatterExtractsSignal()
void	expectCancelDoNotHang()
void	expectInvalidNext()
void	expectInvalidNextMatches()
void	expectInvalidNexts()
void	expectInvalidNextsWithCustomConverter()
void	expectNext()
void	expectNextAsync()
void	expectNextCount()
void	expectNextCount2()
void	expectNextCount3()
void	expectNextCountAfterConsumeNextWith()
void	expectNextCountAfterExpectNext()
void	expectNextCountAfterExpectNextCount()
void	expectNextCountAfterExpectNextMatches()
void	expectNextCountAfterExpectNextSequence()
void	expectNextCountAfterThenConsumeWhile()
void	expectNextCountError()
void	expectNextCountErrorIsSuppressed()
void	expectNextCountLots()
void	expectNextCountLotsError()
void	expectNextCountLotsUnderRequestErrorReportedAtEnd()
void	expectNextCountLowRequestShortcircuits()
void	expectNextCountZero()
void	expectNextCountZeroBeforeExpectNext()
void	expectNextErrorIsSuppressed()
void	expectNextLowRequestShortcircuits()
void	expectNextMatches()
void	expectNextMatchesLowRequestShortcircuits()
void	expectNexts()
void	expectNextSequenceEmptyListBeforeExpectNext()
void	expectNextSequenceErrorIsSuppressed()
void	expectNextSequenceLowRequestShortcircuits()
void	expectNextSequenceWithPartialMatchingSequence()
void	expectNextSequenceWithPartialMatchingSequenceNoMoreExpectation()
void	expectNextsMoreThan6()
void	expectTimeoutSmokeTest()
void	externalGetOrSetTakenIntoAccount()
void	gh783_deferredAdvanceTime()
void	gh783_firstSmallAdvance()
void	gh783_intervalFullyEmitted()
void	gh783_withInnerFlatmap()
void	gh783()
void	initialBoundedThenUnboundedRequestDoesntOverflow()
void	longDelayAndNoTermination()
void	lowRequestCheckCanBeDisabled()
void	missingNext()
void	missingNextAsync()
void	mutualizedSubscribeErrorHandlingPostOnSubscribe()
void	noCancelOnCompleteWhenCountUnexpected()
void	noCancelOnCompleteWhenSequenceUnexpected()
void	noCancelOnErrorWhenCollectUnexpected()
void	noCancelOnUnexpectedCompleteSignal()
void	noCancelOnUnexpectedCompleteSignal2()
void	noCancelOnUnexpectedErrorSignal()
void	noEventExpectationButComplete()
void	noEventExpectationButError()
void	noSignalRealTime()
void	noSignalVirtualTime()
void	parallelVerifyWithVtsMutuallyExclusive()
void	request()
void	requestBufferDoesntOverflow()
void	subscribedTwice()
void	takeAsyncFusedBackpressured()
void	testDurationFailureWithScenarioName()
void	testExpectRecordedMatches()
void	testExpectRecordedMatchesTwice()
void	testExpectRecordedMatchesWithoutComplete()
void	testThenConsumeWhile()
void	testThenConsumeWhileFails()
void	testThenConsumeWhileWithConsumer()
void	testWithDescription()
void	testWithDescriptionAndScenarioName()
void	thenAwaitThenCancelWaitsForDuration()
void	thenCancel_cancelsAfterFirst()
void	thenCancel_cancelsAfterFirst2()
void	thenConsumeWhileLowRequestShortcircuits()
void	verifyCompleteTriggersVerificationFail()
void	verifyCompleteTriggersVerificationSuccess()
void	verifyConsumeSubscription()
void	verifyConsumeSubscriptionAfterFirst()
void	verifyConsumeSubscriptionError()
void	verifyCreatedForAllSchedulerUsesVirtualTime()
void	verifyDrainOnRequestInCaseOfFusion()
void	verifyDuration()
void	verifyDurationTimeout()
void	verifyErrorAssertionTriggersVerificationFailBadSignal()
void	verifyErrorAssertionTriggersVerificationSuccess()
void	verifyErrorClassTriggersVerificationFail()
void	verifyErrorClassTriggersVerificationSuccess()
void	verifyErrorMessageTriggersVerificationFail()
void	verifyErrorMessageTriggersVerificationSuccess()
void	verifyErrorPredicateTriggersVerificationFailBadSignal()
void	verifyErrorPredicateTriggersVerificationFailNoMatch()
void	verifyErrorPredicateTriggersVerificationSuccess()
void	verifyErrorTriggersVerificationFail()
void	verifyErrorTriggersVerificationSuccess()
void	verifyExpectTimeoutDoesntCareAboutSubscription()
void	verifyExpectTimeoutFailsWhenSomeEvent()
void	verifyExpectTimeoutNever()
void	verifyFusion()
void	verifyFusionError()
void	verifyFusionModeExpected()
void	verifyFusionModeExpected2()
void	verifyFusionModeExpected2Error()
void	verifyFusionModeExpectedCancel()
void	verifyFusionModeExpectedError()
void	verifyFusionModeRequest()
void	verifyLaterCanVerifyConnectableFlux_withAssertionErrors()
void	verifyLaterCanVerifyConnectableFlux()
void	verifyNeverWithExpectTimeout()
void	verifyNextAs()
void	verifyNextAs2()
void	verifyNextAsErrorTooFewInIterable()
void	verifyNextAsErrorTooManyInIterable()
void	verifyNextAsWithEmptyFlux()
void	verifyNoFusion()
void	verifyNoFusionError()
void	verifyRecordMatches()
void	verifyRecordMatchesError()
void	verifyRecordMatchesError2()
void	verifyRecordNullError()
void	verifyRecordWith2()
void	verifySubscription()
void	verifySubscriptionError()
void	verifyThenOnCompleteRange()
void	verifyTimeoutSmokeTest()
void	verifyVirtualTimeExpectTimeoutFailsWhenSomeEvent()
void	verifyVirtualTimeExpectTimeoutNever()
void	verifyVirtualTimeNoEvent()
void	verifyVirtualTimeNoEventError()
void	verifyVirtualTimeNoEventInterval()
void	verifyVirtualTimeNoEventIntervalError()
void	verifyVirtualTimeNoScenarioFails()
void	verifyVirtualTimeOnComplete()
void	verifyVirtualTimeOnError()
void	verifyVirtualTimeOnErrorAsync()
void	verifyVirtualTimeOnErrorInterval()
void	verifyVirtualTimeOnNext()
void	verifyVirtualTimeOnNextInterval()
void	verifyVirtualTimeOnNextIntervalManual()
void	verifyVirtualTimeOnSubscribe()
void	virtualTimeNoEventExpectationButComplete()
void	virtualTimeNoEventExpectationButError()
void	virtualTimeSchedulerUseExactlySupplied()
void	virtualTimeSchedulerVeryLong()
void	withInitialContext()
void	withInitialContextAndContextAssertionsParents()
void	withInitialContextButNoPropagation()
void	withVirtualTimeResetsCustomFactoryAndOldSharedThreads()

从类继承的方法 java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

StepVerifierTests

public StepVerifierTests()

方法详细资料

expectationErrorWithGenericValueFormatterBypassesExtractor

@Test
public void expectationErrorWithGenericValueFormatterBypassesExtractor()

expectationErrorWithSpecificValueFormatterExtractsSignal

@Test
public void expectationErrorWithSpecificValueFormatterExtractsSignal()

expectationErrorWithoutValueFormatter

@Test
public void expectationErrorWithoutValueFormatter()

expectInvalidNextsWithCustomConverter

@Test
public void expectInvalidNextsWithCustomConverter()

expectNext

@Test
public void expectNext()

expectInvalidNext

@Test
public void expectInvalidNext()

expectNextAsync

@Test
public void expectNextAsync()

expectNexts

@Test
public void expectNexts()

expectNextsMoreThan6

@Test
public void expectNextsMoreThan6()

expectInvalidNexts

@Test
public void expectInvalidNexts()

expectNextMatches

@Test
public void expectNextMatches()

expectInvalidNextMatches

@Test
public void expectInvalidNextMatches()

consumeNextWith

@Test
public void consumeNextWith()
                            throws java.lang.Exception

抛出:

java.lang.Exception

consumeNextWith2

@Test
public void consumeNextWith2()
                             throws java.lang.Exception

抛出:

java.lang.Exception

missingNext

@Test
public void missingNext()

missingNextAsync

@Test
public void missingNextAsync()

expectNextCount

@Test
public void expectNextCount()

expectNextCountLots

@Test
public void expectNextCountLots()

expectNextCountZeroBeforeExpectNext

@Test
public void expectNextCountZeroBeforeExpectNext()

expectNextCountLotsError

@Test
public void expectNextCountLotsError()

expectNextCountLotsUnderRequestErrorReportedAtEnd

@Test
public void expectNextCountLotsUnderRequestErrorReportedAtEnd()

expectNextCount2

@Test
public void expectNextCount2()

expectNextCount3

@Test
public void expectNextCount3()

expectNextCountZero

@Test
public void expectNextCountZero()

expectNextCountError

@Test
public void expectNextCountError()

error

@Test
public void error()

errorClass

@Test
public void errorClass()

errorMessage

@Test
public void errorMessage()

errorMatches

@Test
public void errorMatches()

errorMatchesInvalid

@Test
public void errorMatchesInvalid()

errorSatisfies

@Test
public void errorSatisfies()

consumeErrorWith

@Test
public void consumeErrorWith()

request

@Test
public void request()

cancel

@Test
public void cancel()

cancelInvalid

@Test
public void cancelInvalid()

thenCancel_cancelsAfterFirst

@Test
public void thenCancel_cancelsAfterFirst()

thenCancel_cancelsAfterFirst2

@Test
public void thenCancel_cancelsAfterFirst2()

subscribedTwice

@Test
public void subscribedTwice()

verifyThenOnCompleteRange

@Test
public void verifyThenOnCompleteRange()

verifyDuration

@Test
public void verifyDuration()

verifyDurationTimeout

@Test
public void verifyDurationTimeout()

verifyNeverWithExpectTimeout

@Test
public void verifyNeverWithExpectTimeout()

verifySubscription

@Test
public void verifySubscription()

verifyNextAs

@Test
public void verifyNextAs()

verifyNextAsErrorTooFewInIterable

@Test
public void verifyNextAsErrorTooFewInIterable()

verifyNextAsErrorTooManyInIterable

@Test
public void verifyNextAsErrorTooManyInIterable()

verifyNextAs2

@Test
public void verifyNextAs2()

verifyNextAsWithEmptyFlux

@Test
public void verifyNextAsWithEmptyFlux()

verifyRecordMatches

@Test
public void verifyRecordMatches()

verifyRecordMatchesError

@Test
public void verifyRecordMatchesError()

verifyRecordNullError

@Test
public void verifyRecordNullError()

verifyRecordMatchesError2

@Test
public void verifyRecordMatchesError2()

verifyRecordWith2

@Test
public void verifyRecordWith2()

verifySubscriptionError

@Test
public void verifySubscriptionError()

verifyConsumeSubscription

@Test
public void verifyConsumeSubscription()

verifyConsumeSubscriptionAfterFirst

@Test
public void verifyConsumeSubscriptionAfterFirst()

verifyConsumeSubscriptionError

@Test
public void verifyConsumeSubscriptionError()

verifyFusion

@Test
public void verifyFusion()

verifyFusionError

@Test
public void verifyFusionError()

verifyNoFusion

@Test
public void verifyNoFusion()

verifyNoFusionError

@Test
public void verifyNoFusionError()

verifyFusionModeRequest

@Test
public void verifyFusionModeRequest()

verifyFusionModeExpected

@Test
public void verifyFusionModeExpected()

verifyFusionModeExpectedError

@Test
public void verifyFusionModeExpectedError()

verifyFusionModeExpected2

@Test
public void verifyFusionModeExpected2()

verifyFusionModeExpectedCancel

@Test
public void verifyFusionModeExpectedCancel()

verifyFusionModeExpected2Error

@Test
public void verifyFusionModeExpected2Error()

verifyVirtualTimeOnSubscribe

@Test
public void verifyVirtualTimeOnSubscribe()

verifyVirtualTimeOnError

@Test
public void verifyVirtualTimeOnError()

verifyVirtualTimeNoEvent

@Test
public void verifyVirtualTimeNoEvent()

verifyVirtualTimeNoEventError

@Test
public void verifyVirtualTimeNoEventError()

verifyVirtualTimeNoEventInterval

@Test
public void verifyVirtualTimeNoEventInterval()

verifyVirtualTimeNoEventIntervalError

@Test
public void verifyVirtualTimeNoEventIntervalError()

verifyExpectTimeoutFailsWhenSomeEvent

@Test
public void verifyExpectTimeoutFailsWhenSomeEvent()

verifyVirtualTimeExpectTimeoutFailsWhenSomeEvent

@Test
public void verifyVirtualTimeExpectTimeoutFailsWhenSomeEvent()

verifyExpectTimeoutNever

@Test
public void verifyExpectTimeoutNever()

verifyVirtualTimeExpectTimeoutNever

@Test
public void verifyVirtualTimeExpectTimeoutNever()

verifyExpectTimeoutDoesntCareAboutSubscription

@Test
public void verifyExpectTimeoutDoesntCareAboutSubscription()

verifyVirtualTimeOnNext

@Test
public void verifyVirtualTimeOnNext()

verifyVirtualTimeOnComplete

@Test
public void verifyVirtualTimeOnComplete()

verifyVirtualTimeOnNextInterval

@Test
public void verifyVirtualTimeOnNextInterval()

verifyVirtualTimeNoScenarioFails

@Test
public void verifyVirtualTimeNoScenarioFails()

verifyVirtualTimeOnNextIntervalManual

@Test
 @Timeout(value=3000L,
         unit=MILLISECONDS)
public void verifyVirtualTimeOnNextIntervalManual()

verifyVirtualTimeOnErrorInterval

@Test
public void verifyVirtualTimeOnErrorInterval()

verifyVirtualTimeOnErrorAsync

@Test
public void verifyVirtualTimeOnErrorAsync()

verifyCreatedForAllSchedulerUsesVirtualTime

@Test
 @Timeout(value=1000L,
         unit=MILLISECONDS)
public void verifyCreatedForAllSchedulerUsesVirtualTime()

noSignalRealTime

@Test
public void noSignalRealTime()

noSignalVirtualTime

@Test
 @Timeout(value=500L,
         unit=MILLISECONDS)
public void noSignalVirtualTime()

longDelayAndNoTermination

@Test
public void longDelayAndNoTermination()

expectTimeoutSmokeTest

@Test
public void expectTimeoutSmokeTest()

verifyTimeoutSmokeTest

@Test
public void verifyTimeoutSmokeTest()

thenAwaitThenCancelWaitsForDuration

@Test
public void thenAwaitThenCancelWaitsForDuration()

testThenConsumeWhile

@Test
public void testThenConsumeWhile()

testThenConsumeWhileWithConsumer

@Test
public void testThenConsumeWhileWithConsumer()

testThenConsumeWhileFails

@Test
public void testThenConsumeWhileFails()

testExpectRecordedMatches

@Test
public void testExpectRecordedMatches()

testExpectRecordedMatchesTwice

@Test
public void testExpectRecordedMatchesTwice()

testExpectRecordedMatchesWithoutComplete

@Test
public void testExpectRecordedMatchesWithoutComplete()

testWithDescription

@Test
public void testWithDescription()

testWithDescriptionAndScenarioName

@Test
public void testWithDescriptionAndScenarioName()

testDurationFailureWithScenarioName

@Test
public void testDurationFailureWithScenarioName()

noCancelOnUnexpectedErrorSignal

@Test
public void noCancelOnUnexpectedErrorSignal()

noCancelOnUnexpectedCompleteSignal

@Test
public void noCancelOnUnexpectedCompleteSignal()

noCancelOnUnexpectedCompleteSignal2

@Test
public void noCancelOnUnexpectedCompleteSignal2()

noCancelOnCompleteWhenSequenceUnexpected

@Test
public void noCancelOnCompleteWhenSequenceUnexpected()

noCancelOnCompleteWhenCountUnexpected

@Test
public void noCancelOnCompleteWhenCountUnexpected()

noCancelOnErrorWhenCollectUnexpected

@Test
public void noCancelOnErrorWhenCollectUnexpected()

cancelOnUnexpectedNextWithMoreData

@Test
public void cancelOnUnexpectedNextWithMoreData()

boundedInitialOverflowIsDetected

@Test
public void boundedInitialOverflowIsDetected()

boundedRequestOverflowIsDetected

@Test
public void boundedRequestOverflowIsDetected()

initialBoundedThenUnboundedRequestDoesntOverflow

@Test
public void initialBoundedThenUnboundedRequestDoesntOverflow()

verifyErrorTriggersVerificationFail

@Test
public void verifyErrorTriggersVerificationFail()

verifyErrorTriggersVerificationSuccess

@Test
public void verifyErrorTriggersVerificationSuccess()

verifyErrorClassTriggersVerificationFail

@Test
public void verifyErrorClassTriggersVerificationFail()

verifyErrorClassTriggersVerificationSuccess

@Test
public void verifyErrorClassTriggersVerificationSuccess()

verifyErrorMessageTriggersVerificationFail

@Test
public void verifyErrorMessageTriggersVerificationFail()

verifyErrorMessageTriggersVerificationSuccess

@Test
public void verifyErrorMessageTriggersVerificationSuccess()

verifyErrorPredicateTriggersVerificationFailBadSignal

@Test
public void verifyErrorPredicateTriggersVerificationFailBadSignal()

verifyErrorPredicateTriggersVerificationFailNoMatch

@Test
public void verifyErrorPredicateTriggersVerificationFailNoMatch()

verifyErrorPredicateTriggersVerificationSuccess

@Test
public void verifyErrorPredicateTriggersVerificationSuccess()

verifyErrorAssertionTriggersVerificationFailBadSignal

@Test
public void verifyErrorAssertionTriggersVerificationFailBadSignal()

verifyErrorAssertionTriggersVerificationSuccess

@Test
public void verifyErrorAssertionTriggersVerificationSuccess()

verifyCompleteTriggersVerificationFail

@Test
public void verifyCompleteTriggersVerificationFail()

verifyCompleteTriggersVerificationSuccess

@Test
public void verifyCompleteTriggersVerificationSuccess()

expectNextCountAfterExpectNext

@Test
public void expectNextCountAfterExpectNext()

expectNextCountAfterThenConsumeWhile

@Test
public void expectNextCountAfterThenConsumeWhile()

expectNextCountAfterExpectNextCount

@Test
public void expectNextCountAfterExpectNextCount()

expectNextCountAfterExpectNextMatches

@Test
public void expectNextCountAfterExpectNextMatches()

expectNextCountAfterExpectNextSequence

@Test
public void expectNextCountAfterExpectNextSequence()

expectNextCountAfterConsumeNextWith

@Test
public void expectNextCountAfterConsumeNextWith()

expectNextSequenceWithPartialMatchingSequence

@Test
public void expectNextSequenceWithPartialMatchingSequence()

expectNextSequenceWithPartialMatchingSequenceNoMoreExpectation

@Test
public void expectNextSequenceWithPartialMatchingSequenceNoMoreExpectation()

expectNextSequenceEmptyListBeforeExpectNext

@Test
public void expectNextSequenceEmptyListBeforeExpectNext()

expectNextErrorIsSuppressed

@Test
public void expectNextErrorIsSuppressed()

consumeNextErrorIsSuppressed

@Test
public void consumeNextErrorIsSuppressed()

expectNextCountErrorIsSuppressed

@Test
public void expectNextCountErrorIsSuppressed()

expectNextSequenceErrorIsSuppressed

@Test
public void expectNextSequenceErrorIsSuppressed()

consumeWhileErrorIsSuppressed

@Test
public void consumeWhileErrorIsSuppressed()

requestBufferDoesntOverflow

@Test
public void requestBufferDoesntOverflow()

expectCancelDoNotHang

@Test
 @Timeout(value=1000L,
         unit=MILLISECONDS)
public void expectCancelDoNotHang()

consumeNextWithLowRequestShortcircuits

@Test
 @Timeout(value=1000L,
         unit=MILLISECONDS)
public void consumeNextWithLowRequestShortcircuits()

assertNextLowRequestShortcircuits

@Test
 @Timeout(value=1000L,
         unit=MILLISECONDS)
public void assertNextLowRequestShortcircuits()

expectNextLowRequestShortcircuits

@Test
 @Timeout(value=1000L,
         unit=MILLISECONDS)
public void expectNextLowRequestShortcircuits()

expectNextCountLowRequestShortcircuits

@Test
 @Timeout(value=1000L,
         unit=MILLISECONDS)
public void expectNextCountLowRequestShortcircuits()

expectNextMatchesLowRequestShortcircuits

@Test
 @Timeout(value=1000L,
         unit=MILLISECONDS)
public void expectNextMatchesLowRequestShortcircuits()

expectNextSequenceLowRequestShortcircuits

@Test
 @Timeout(value=1000L,
         unit=MILLISECONDS)
public void expectNextSequenceLowRequestShortcircuits()

thenConsumeWhileLowRequestShortcircuits

@Test
 @Timeout(value=1000L,
         unit=MILLISECONDS)
public void thenConsumeWhileLowRequestShortcircuits()

lowRequestCheckCanBeDisabled

@Test
 @Timeout(value=1000L,
         unit=MILLISECONDS)
public void lowRequestCheckCanBeDisabled()

takeAsyncFusedBackpressured

@Test
public void takeAsyncFusedBackpressured()

cancelAsyncFusion

@Test
public void cancelAsyncFusion()

virtualTimeSchedulerUseExactlySupplied

@Test
public void virtualTimeSchedulerUseExactlySupplied()

virtualTimeSchedulerVeryLong

@Test
public void virtualTimeSchedulerVeryLong()

withInitialContext

@Test
public void withInitialContext()

withInitialContextButNoPropagation

@Test
public void withInitialContextButNoPropagation()

withInitialContextAndContextAssertionsParents

@Test
public void withInitialContextAndContextAssertionsParents()

assertNextWithSubscribeOnSink

@Test
public void assertNextWithSubscribeOnSink()

assertNextWithSubscribeOnJust

@Test
public void assertNextWithSubscribeOnJust()

parallelVerifyWithVtsMutuallyExclusive

@Test
public void parallelVerifyWithVtsMutuallyExclusive()

gh783

@Test
 @Timeout(value=5L)
public void gh783()

gh783_deferredAdvanceTime

@Test
 @Timeout(value=5L)
public void gh783_deferredAdvanceTime()

gh783_withInnerFlatmap

@Test
 @Disabled
public void gh783_withInnerFlatmap()

gh783_intervalFullyEmitted

@Test
public void gh783_intervalFullyEmitted()

gh783_firstSmallAdvance

@Test
public void gh783_firstSmallAdvance()

noEventExpectationButComplete

@Test
public void noEventExpectationButComplete()

noEventExpectationButError

@Test
public void noEventExpectationButError()

virtualTimeNoEventExpectationButComplete

@Test
public void virtualTimeNoEventExpectationButComplete()

virtualTimeNoEventExpectationButError

@Test
public void virtualTimeNoEventExpectationButError()

verifyLaterCanVerifyConnectableFlux

@Test
public void verifyLaterCanVerifyConnectableFlux()

verifyLaterCanVerifyConnectableFlux_withAssertionErrors

@Test
public void verifyLaterCanVerifyConnectableFlux_withAssertionErrors()

verifyDrainOnRequestInCaseOfFusion

@Test
public void verifyDrainOnRequestInCaseOfFusion()

externalGetOrSetTakenIntoAccount

@Test
public void externalGetOrSetTakenIntoAccount()

mutualizedSubscribeErrorHandlingPostOnSubscribe

@Test
public void mutualizedSubscribeErrorHandlingPostOnSubscribe()

withVirtualTimeResetsCustomFactoryAndOldSharedThreads

@Test
public void withVirtualTimeResetsCustomFactoryAndOldSharedThreads()