reactor.core.publisher

类 FluxGroupByTest

java.lang.Object

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

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

reactor.core.publisher.FluxGroupByTest

public class FluxGroupByTest
extends FluxOperatorTest<java.lang.String,GroupedFlux<java.lang.Integer,java.lang.String>>

嵌套类概要

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

FluxOperatorTest.Scenario<I,O>

构造器概要

构造器

构造器和说明
FluxGroupByTest()

方法概要

限定符和类型	方法和说明
void	backpressure()
void	concatMapBack()
void	concatMapBackHidden()
void	empty()
void	error()
void	flatMapBack()
void	flatMapBackHidden()
void	fusedGroupByParallel()
void	groupsCompleteAsSoonAsMainCompletes()
void	groupsCompleteAsSoonAsMainCompletesNoFusion()
void	keySelectorNull()
void	normal()
void	normalValueSelector()
void	oneGroupLongMerge()
void	oneGroupLongMergeHidden()
void	prefetchIsUsed()
void	prefetchMaxRequestsUnbounded()
void	scanMain()
void	scanOperator()
void	scanUnicastGroupedFlux()
void	takeTwoGroupsOnly()
void	twoGroupsConsumeWithSubscribe()
void	twoGroupsConsumeWithSubscribeHide()
void	twoGroupsConsumeWithSubscribePrefetchBigger()
void	twoGroupsConsumeWithSubscribePrefetchSmaller()
void	twoGroupsFullAsync()
void	twoGroupsFullAsyncFullHide()
void	twoGroupsLongAsyncMerge()
void	twoGroupsLongAsyncMergeHidden()
void	twoGroupsLongAsyncMergeHidden2()
void	twoGroupsLongMerge()
void	twoGroupsLongMergeHidden()
void	valueSelectorNull()

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

构造器详细资料

FluxGroupByTest

public FluxGroupByTest()

方法详细资料

normal

@Test
public void normal()

normalValueSelector

@Test
public void normalValueSelector()

takeTwoGroupsOnly

@Test
public void takeTwoGroupsOnly()

keySelectorNull

@Test
public void keySelectorNull()

valueSelectorNull

@Test
public void valueSelectorNull()

error

@Test
public void error()

backpressure

@Test
public void backpressure()

flatMapBack

@Test
public void flatMapBack()

flatMapBackHidden

@Test
public void flatMapBackHidden()

concatMapBack

@Test
public void concatMapBack()

concatMapBackHidden

@Test
public void concatMapBackHidden()

empty

@Test
public void empty()

oneGroupLongMerge

@Test
public void oneGroupLongMerge()

oneGroupLongMergeHidden

@Test
public void oneGroupLongMergeHidden()

twoGroupsLongMerge

@Test
public void twoGroupsLongMerge()

twoGroupsLongMergeHidden

@Test
public void twoGroupsLongMergeHidden()

twoGroupsLongAsyncMerge

@Test
public void twoGroupsLongAsyncMerge()

twoGroupsLongAsyncMergeHidden

@Test
public void twoGroupsLongAsyncMergeHidden()

twoGroupsLongAsyncMergeHidden2

@Test
 @Tag(value="slow")
public void twoGroupsLongAsyncMergeHidden2()

twoGroupsConsumeWithSubscribe

@Test
public void twoGroupsConsumeWithSubscribe()

twoGroupsConsumeWithSubscribePrefetchSmaller

@Test
public void twoGroupsConsumeWithSubscribePrefetchSmaller()

twoGroupsConsumeWithSubscribePrefetchBigger

@Test
public void twoGroupsConsumeWithSubscribePrefetchBigger()

twoGroupsConsumeWithSubscribeHide

@Test
public void twoGroupsConsumeWithSubscribeHide()

twoGroupsFullAsyncFullHide

@Test
 @Disabled(value="temporarily disabled, see gh-1028")
public void twoGroupsFullAsyncFullHide()

twoGroupsFullAsync

@Test
 @Disabled(value="temporarily disabled, see gh-1028")
public void twoGroupsFullAsync()

groupsCompleteAsSoonAsMainCompletes

@Test
public void groupsCompleteAsSoonAsMainCompletes()

groupsCompleteAsSoonAsMainCompletesNoFusion

@Test
public void groupsCompleteAsSoonAsMainCompletesNoFusion()

prefetchIsUsed

@Test
public void prefetchIsUsed()

prefetchMaxRequestsUnbounded

@Test
public void prefetchMaxRequestsUnbounded()

scanOperator

@Test
public void scanOperator()

scanMain

@Test
public void scanMain()

scanUnicastGroupedFlux

@Test
public void scanUnicastGroupedFlux()

fusedGroupByParallel

@Test
 @Timeout(value=10L)
public void fusedGroupByParallel()