reactor.core.publisher

类 FluxGenerateTest

java.lang.Object

reactor.core.publisher.FluxGenerateTest

public class FluxGenerateTest
extends java.lang.Object

构造器概要

构造器

构造器和说明
FluxGenerateTest()

方法概要

限定符和类型	方法和说明
void	fusedGeneratedNextAndErrorPropagateException()
void	fusedGenerateErrorThrowsPropagateException()
void	fusion()
void	fusionBoundary()
void	generateEmpty()
void	generateError()
void	generateJust()
void	generateJustBackpressured()
void	generateRange()
void	generateRangeBackpressured()
void	generatorMultipleOnCompletes()
void	generatorMultipleOnErrors()
void	generatorMultipleOnNexts()
void	generatorNull()
void	generatorThrows()
void	generatorThrowsFusion()
void	iterableSource()
void	iterableSourceBackpressured()
void	scanOperator()
void	scanSubscription()
void	scanSubscriptionCancelled()
void	scanSubscriptionError()
void	sinkNotUsed()
void	sinkNotUsedFusion()
void	stateConsumerCalled()
void	stateConsumerNull()
void	stateSupplierNull()
void	stateSupplierThrows()

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

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

构造器详细资料

FluxGenerateTest

public FluxGenerateTest()

方法详细资料

stateSupplierNull

@Test
public void stateSupplierNull()

generatorNull

@Test
public void generatorNull()

stateConsumerNull

@Test
public void stateConsumerNull()

sinkNotUsed

@Test
public void sinkNotUsed()

sinkNotUsedFusion

@Test
public void sinkNotUsedFusion()

generateEmpty

@Test
public void generateEmpty()

generateJust

@Test
public void generateJust()

generateError

@Test
public void generateError()

generateJustBackpressured

@Test
public void generateJustBackpressured()

generateRange

@Test
public void generateRange()

generateRangeBackpressured

@Test
public void generateRangeBackpressured()

stateSupplierThrows

@Test
public void stateSupplierThrows()

generatorThrows

@Test
public void generatorThrows()

generatorThrowsFusion

@Test
public void generatorThrowsFusion()

generatorMultipleOnErrors

@Test
public void generatorMultipleOnErrors()

generatorMultipleOnCompletes

@Test
public void generatorMultipleOnCompletes()

generatorMultipleOnNexts

@Test
public void generatorMultipleOnNexts()

stateConsumerCalled

@Test
public void stateConsumerCalled()

iterableSource

@Test
public void iterableSource()

iterableSourceBackpressured

@Test
public void iterableSourceBackpressured()

fusion

@Test
public void fusion()

fusionBoundary

@Test
public void fusionBoundary()

scanOperator

@Test
public void scanOperator()

scanSubscription

@Test
public void scanSubscription()

scanSubscriptionError

@Test
public void scanSubscriptionError()

scanSubscriptionCancelled

@Test
public void scanSubscriptionCancelled()

fusedGeneratedNextAndErrorPropagateException

@Test
public void fusedGeneratedNextAndErrorPropagateException()

fusedGenerateErrorThrowsPropagateException

@Test
public void fusedGenerateErrorThrowsPropagateException()