reactor.core.publisher

类 MonoCacheTimeTest

java.lang.Object

reactor.test.publisher.BaseOperatorTest<I,Mono<I>,O,Mono<O>>

reactor.test.publisher.MonoOperatorTest<java.lang.String,java.lang.String>

reactor.core.publisher.MonoCacheTimeTest

public class MonoCacheTimeTest
extends MonoOperatorTest<java.lang.String,java.lang.String>

嵌套类概要

从类继承的嵌套类/接口 reactor.test.publisher.MonoOperatorTest

MonoOperatorTest.Scenario<I,O>

构造器概要

构造器

构造器和说明
MonoCacheTimeTest()

方法概要

限定符和类型	方法和说明
void	cacheDependingOnEmpty()
void	cacheDependingOnSignal()
void	cacheDependingOnValueAndError()
void	contextFromFirstSubscriberCached()
void	coordinatorCacheInnerDisposedOrNoReferenceNoLeak()
void	coordinatorNoReferenceNoLeak()
void	coordinatorReachableThroughCacheInnerSubscriptionsOnly()
void	doesntResubscribeConditional()
void	doesntResubscribeNormal()
void	emptyTtlGeneratorFailure()
void	emptyTtlGeneratorTransientFailure()
void	emptyTtlGeneratorTransientFailureCheckHooks()
void	errorTtlGeneratorFailure()
void	errorTtlGeneratorTransientFailure()
void	errorTtlGeneratorTransientFailureCheckHooks()
void	expireAfterTtlConditional()
void	expireAfterTtlNormal()
void	longMaxDurationSchedulesNothing()
void	nextTtlGeneratorFailure()
void	nextTtlGeneratorTransientFailure()
void	nextTtlGeneratorTransientFailureCheckHooks()
void	nonZeroDurationSchedulesSomething()
void	noTtlCancelDoesntCancelSource()
void	partialCancelDoesntCancelSource()
void	raceSubscribeAndCache()
void	scanCoordinatorSubscriber()
void	scanOperator()
void	scanSubscriber()
void	signalDependentWithSchedulerOperatorTests()
void	sourceCachedNoCoordinatorLeak()
void	totalCancelCanResubscribe()
void	totalCancelDoesntCancelSource()
void	transientErrorWithZeroTtlIsNotCached()
void	zeroDurationSchedulesNothing()

从类继承的方法 reactor.test.publisher.MonoOperatorTest

scenario

从类继承的方法 reactor.test.publisher.BaseOperatorTest

assertPrePostState, cancelOnSubscribe, errorOnSubscribe, initDefaultScenario, sequenceOfNextAndCancel, sequenceOfNextAndComplete, sequenceOfNextAndError, sequenceOfNextWithCallbackError

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

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

构造器详细资料

MonoCacheTimeTest

public MonoCacheTimeTest()

方法详细资料

cacheDependingOnSignal

@Test
public void cacheDependingOnSignal()
                                   throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

cacheDependingOnValueAndError

@Test
public void cacheDependingOnValueAndError()
                                          throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

cacheDependingOnEmpty

@Test
public void cacheDependingOnEmpty()
                                  throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

nextTtlGeneratorFailure

@Test
public void nextTtlGeneratorFailure()

emptyTtlGeneratorFailure

@Test
public void emptyTtlGeneratorFailure()

errorTtlGeneratorFailure

@Test
public void errorTtlGeneratorFailure()

nextTtlGeneratorTransientFailure

@Test
public void nextTtlGeneratorTransientFailure()

emptyTtlGeneratorTransientFailure

@Test
public void emptyTtlGeneratorTransientFailure()

errorTtlGeneratorTransientFailure

@Test
public void errorTtlGeneratorTransientFailure()

nextTtlGeneratorTransientFailureCheckHooks

@Test
public void nextTtlGeneratorTransientFailureCheckHooks()

emptyTtlGeneratorTransientFailureCheckHooks

@Test
public void emptyTtlGeneratorTransientFailureCheckHooks()

errorTtlGeneratorTransientFailureCheckHooks

@Test
public void errorTtlGeneratorTransientFailureCheckHooks()

transientErrorWithZeroTtlIsNotCached

@Test
public void transientErrorWithZeroTtlIsNotCached()

expireAfterTtlNormal

@Test
public void expireAfterTtlNormal()

doesntResubscribeNormal

@Test
public void doesntResubscribeNormal()

expireAfterTtlConditional

@Test
public void expireAfterTtlConditional()

doesntResubscribeConditional

@Test
public void doesntResubscribeConditional()

totalCancelDoesntCancelSource

@Test
public void totalCancelDoesntCancelSource()

totalCancelCanResubscribe

@Test
public void totalCancelCanResubscribe()

partialCancelDoesntCancelSource

@Test
public void partialCancelDoesntCancelSource()

raceSubscribeAndCache

@Test
public void raceSubscribeAndCache()

sourceCachedNoCoordinatorLeak

@Test
public void sourceCachedNoCoordinatorLeak()

coordinatorReachableThroughCacheInnerSubscriptionsOnly

@Test
public void coordinatorReachableThroughCacheInnerSubscriptionsOnly()
                                                                   throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

coordinatorCacheInnerDisposedOrNoReferenceNoLeak

@Test
public void coordinatorCacheInnerDisposedOrNoReferenceNoLeak()
                                                             throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

coordinatorNoReferenceNoLeak

@Test
public void coordinatorNoReferenceNoLeak()
                                         throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

contextFromFirstSubscriberCached

@Test
public void contextFromFirstSubscriberCached()

longMaxDurationSchedulesNothing

@Test
public void longMaxDurationSchedulesNothing()

nonZeroDurationSchedulesSomething

@Test
public void nonZeroDurationSchedulesSomething()

zeroDurationSchedulesNothing

@Test
public void zeroDurationSchedulesNothing()

noTtlCancelDoesntCancelSource

@Test
public void noTtlCancelDoesntCancelSource()

scanOperator

@Test
public void scanOperator()

scanCoordinatorSubscriber

@Test
public void scanCoordinatorSubscriber()

scanSubscriber

@Test
public void scanSubscriber()

signalDependentWithSchedulerOperatorTests

@Test
public void signalDependentWithSchedulerOperatorTests()