reactor.core.publisher

类 MonoReduceTest

java.lang.Object

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

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

reactor.core.publisher.MonoReduceTest

public class MonoReduceTest
extends ReduceOperatorTest<java.lang.String,java.lang.String>

嵌套类概要

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

ReduceOperatorTest.Scenario<I,O>

构造器概要

构造器

构造器和说明
MonoReduceTest()

方法概要

限定符和类型	方法和说明
void	aggregatorReturnsNull()
void	aggregatorThrows()
void	discardAccumulatedOnCancel()
void	discardOnError()
void	empty()
void	error()
void	noRetainValueOnComplete()
void	noRetainValueOnError()
void	normal()
void	normalBackpressured()
void	onNextAndCancelRace()
void	scanOperator()
void	scanSubscriberCancelledScenario()
void	scanSubscriberTerminatedScenario()
void	should_reduce_to_10_events()
void	single()

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

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

构造器详细资料

MonoReduceTest

public MonoReduceTest()

方法详细资料

normal

@Test
public void normal()

normalBackpressured

@Test
public void normalBackpressured()

single

@Test
public void single()

empty

@Test
public void empty()

error

@Test
public void error()

aggregatorThrows

@Test
public void aggregatorThrows()

aggregatorReturnsNull

@Test
public void aggregatorReturnsNull()

should_reduce_to_10_events

@Test
public void should_reduce_to_10_events()

onNextAndCancelRace

@Test
public void onNextAndCancelRace()

discardAccumulatedOnCancel

@Test
public void discardAccumulatedOnCancel()

discardOnError

@Test
public void discardOnError()

noRetainValueOnComplete

@Test
public void noRetainValueOnComplete()

noRetainValueOnError

@Test
public void noRetainValueOnError()

scanOperator

@Test
public void scanOperator()

scanSubscriberTerminatedScenario

@Test
public void scanSubscriberTerminatedScenario()

scanSubscriberCancelledScenario

@Test
public void scanSubscriberCancelledScenario()