reactor.core.publisher

类 FluxReplayTest

java.lang.Object

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

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

reactor.core.publisher.FluxReplayTest

public class FluxReplayTest
extends FluxOperatorTest<java.lang.String,java.lang.String>

嵌套类概要

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

FluxOperatorTest.Scenario<I,O>

构造器概要

构造器

构造器和说明
FluxReplayTest()

方法概要

限定符和类型	方法和说明
void	cacheFlux()
void	cacheFluxFused()
void	cacheFluxHistoryTTL()
void	cacheFluxHistoryTTLFused()
void	cacheFluxTTL()
void	cacheFluxTTLFused()
void	cacheFluxTTLMillis()
void	cacheFluxTTLNanos()
void	cacheNotOverrunByMaxPrefetch()
void	cacheSingleSubscriberWithMultipleRequestsDoesntHang()
void	cancel()
void	failPrefetch()
void	failTime()
void	ifNoSubscriptionBeforeConnectThenPrefetches()
void	ifSubscribeBeforeConnectThenTrackFurtherRequests()
void	minimalInitialRequestIsHistory()
void	minimalInitialRequestIsMaxOfSubscribersInitialRequests()
void	minimalInitialRequestUnboundedWithFused()
void	minimalInitialRequestWithUnboundedSubscriber()
void	multipleEarlySubscribersPropagateTheirLateRequests()
void	onlyInitialRequestWithLateUnboundedSubscriber()
void	scanInner()
void	scanMain()
void	scanSubscriber()
void	vtsStart(org.junit.jupiter.api.TestInfo testInfo)
void	vtsStop()

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

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

构造器详细资料

FluxReplayTest

public FluxReplayTest()

方法详细资料

vtsStart

@BeforeEach
public void vtsStart(org.junit.jupiter.api.TestInfo testInfo)

vtsStop

@AfterEach
public void vtsStop()

failPrefetch

@Test
public void failPrefetch()

failTime

@Test
public void failTime()

cacheFlux

@Test
 @Tag(value="VirtualTime")
public void cacheFlux()

cacheFluxFused

@Test
 @Tag(value="VirtualTime")
public void cacheFluxFused()

cacheFluxTTL

@Test
 @Tag(value="VirtualTime")
public void cacheFluxTTL()

cacheFluxTTLFused

@Test
 @Tag(value="VirtualTime")
public void cacheFluxTTLFused()

cacheFluxTTLMillis

@Test
 @Tag(value="VirtualTime")
public void cacheFluxTTLMillis()

cacheFluxTTLNanos

@Test
 @Tag(value="VirtualTime")
public void cacheFluxTTLNanos()

cacheFluxHistoryTTL

@Test
 @Tag(value="VirtualTime")
public void cacheFluxHistoryTTL()

cacheFluxHistoryTTLFused

@Test
 @Tag(value="VirtualTime")
public void cacheFluxHistoryTTLFused()

minimalInitialRequestIsHistory

@Test
public void minimalInitialRequestIsHistory()

minimalInitialRequestIsMaxOfSubscribersInitialRequests

@Test
public void minimalInitialRequestIsMaxOfSubscribersInitialRequests()

multipleEarlySubscribersPropagateTheirLateRequests

@Test
public void multipleEarlySubscribersPropagateTheirLateRequests()

minimalInitialRequestWithUnboundedSubscriber

@Test
public void minimalInitialRequestWithUnboundedSubscriber()

minimalInitialRequestUnboundedWithFused

@Test
public void minimalInitialRequestUnboundedWithFused()

onlyInitialRequestWithLateUnboundedSubscriber

@Test
public void onlyInitialRequestWithLateUnboundedSubscriber()

cancel

@Test
public void cancel()

scanMain

@Test
public void scanMain()

scanInner

@Test
public void scanInner()

scanSubscriber

@Test
public void scanSubscriber()

cacheSingleSubscriberWithMultipleRequestsDoesntHang

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

cacheNotOverrunByMaxPrefetch

@Test
public void cacheNotOverrunByMaxPrefetch()

ifSubscribeBeforeConnectThenTrackFurtherRequests

@Test
public void ifSubscribeBeforeConnectThenTrackFurtherRequests()

ifNoSubscriptionBeforeConnectThenPrefetches

@Test
public void ifNoSubscriptionBeforeConnectThenPrefetches()