reactor.core.publisher

类 FluxMapTest

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.FluxMapTest

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

嵌套类概要

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

FluxOperatorTest.Scenario<I,O>

构造器概要

构造器

构造器和说明
FluxMapTest()

方法概要

限定符和类型	方法和说明
void	asyncFusion()
void	asyncFusionBackpressured()
void	hiddenMapFilter()
void	hiddenMapFilterBackpressured()
void	hiddenMapHiddenFilterBackpressured()
void	mapFailureStrategyCustomResume()
void	mapFailureStrategyResume()
void	mapFilter()
void	mapFilterBackpressured()
void	mapFuseableFailureStrategyResume()
void	mapFuseableTryOnNextFailureStrategyResume()
void	mapperThrows()
void	mapTryOnNextFailureStrategyResume()
void	nullMapper()
void	nullSource()
void	scanConditionalSubscriber()
void	scanFuseableConditionalSubscriber()
void	scanFuseableOperator()
void	scanFuseableSubscriber()
void	scanOperator()
void	scanSubscriber()
void	simpleMapping()
void	simpleMappingBackpressured()
void	syncFusion()

从类继承的方法 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

构造器详细资料

FluxMapTest

public FluxMapTest()

方法详细资料

nullSource

@Test
public void nullSource()

nullMapper

@Test
public void nullMapper()

simpleMapping

@Test
public void simpleMapping()

simpleMappingBackpressured

@Test
public void simpleMappingBackpressured()

mapperThrows

@Test
public void mapperThrows()

syncFusion

@Test
public void syncFusion()

asyncFusion

@Test
public void asyncFusion()

asyncFusionBackpressured

@Test
public void asyncFusionBackpressured()

mapFilter

@Test
public void mapFilter()

mapFilterBackpressured

@Test
public void mapFilterBackpressured()

hiddenMapFilter

@Test
public void hiddenMapFilter()

hiddenMapFilterBackpressured

@Test
public void hiddenMapFilterBackpressured()

hiddenMapHiddenFilterBackpressured

@Test
public void hiddenMapHiddenFilterBackpressured()

scanOperator

@Test
public void scanOperator()

scanSubscriber

@Test
public void scanSubscriber()

scanConditionalSubscriber

@Test
public void scanConditionalSubscriber()

scanFuseableOperator

@Test
public void scanFuseableOperator()

scanFuseableSubscriber

@Test
public void scanFuseableSubscriber()

scanFuseableConditionalSubscriber

@Test
public void scanFuseableConditionalSubscriber()

mapFailureStrategyResume

@Test
public void mapFailureStrategyResume()

mapFailureStrategyCustomResume

@Test
public void mapFailureStrategyCustomResume()

mapTryOnNextFailureStrategyResume

@Test
public void mapTryOnNextFailureStrategyResume()

mapFuseableFailureStrategyResume

@Test
public void mapFuseableFailureStrategyResume()

mapFuseableTryOnNextFailureStrategyResume

@Test
public void mapFuseableTryOnNextFailureStrategyResume()