reactor.core.publisher

类 FluxScanSeedTest

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

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

嵌套类概要

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

FluxOperatorTest.Scenario<I,O>

构造器概要

构造器

构造器和说明
FluxScanSeedTest()

方法概要

限定符和类型	方法和说明
void	accumulatorNull()
void	accumulatorReturnsNull()
void	accumulatorThrows()
void	initialValueNull()
void	noRetainValueOnComplete()
void	noRetainValueOnError()
void	normal()
void	normalBackpressured()
void	onlyConsumerPartOfRange()
void	onNextAndCancelRaceDontPassNullToAccumulator()
void	scanCoordinator()
void	scanOperator()
void	scanSubscriber()
void	sourceNull()

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

构造器详细资料

FluxScanSeedTest

public FluxScanSeedTest()

方法详细资料

sourceNull

@Test
public void sourceNull()

initialValueNull

@Test
public void initialValueNull()

accumulatorNull

@Test
public void accumulatorNull()

normal

@Test
public void normal()

normalBackpressured

@Test
public void normalBackpressured()

accumulatorThrows

@Test
public void accumulatorThrows()

accumulatorReturnsNull

@Test
public void accumulatorReturnsNull()

onNextAndCancelRaceDontPassNullToAccumulator

@Test
public void onNextAndCancelRaceDontPassNullToAccumulator()

noRetainValueOnComplete

@Test
public void noRetainValueOnComplete()

noRetainValueOnError

@Test
public void noRetainValueOnError()

scanOperator

@Test
public void scanOperator()

scanCoordinator

@Test
public void scanCoordinator()

scanSubscriber

@Test
public void scanSubscriber()

onlyConsumerPartOfRange

@Test
public void onlyConsumerPartOfRange()