reactor.core.publisher

类 FluxDistinctTest

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

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

嵌套类概要

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

FluxOperatorTest.Scenario<I,O>

构造器概要

构造器

构造器和说明
FluxDistinctTest()

方法概要

限定符和类型	方法和说明
void	allDistinct()
void	allDistinctBackpressured()
void	allDistinctBackpressuredHide()
void	allDistinctHide()
void	allSame()
void	allSameBackpressured()
void	allSameFusable()
void	cleanupNull()
void	collectionSupplierLimitedFifo()
void	collectionSupplierNull()
void	collectionSupplierNullFuseable()
void	collectionSupplierReturnsNull()
void	collectionSupplierThrows()
void	distinctCustomCollectionCustomPredicate()
void	distinctDefaultCancelDoesntRetainObjects()
void	distinctDefaultDoesntRetainObjects()
void	distinctDefaultErrorDoesntRetainObjects()
void	distinctDefaultWithHashcodeCollisions()
void	distinctPredicateNull()
void	distinctPredicateThrows()
void	distinctPredicateThrowsConditional()
void	distinctPredicateThrowsConditionalOnNext()
void	doesntRetainObjectsWithForcedCancelOnSubscriber_conditional()
void	doesntRetainObjectsWithForcedCancelOnSubscriber()
void	doesntRetainObjectsWithForcedCompleteOnSubscriber_conditional()
void	doesntRetainObjectsWithForcedCompleteOnSubscriber()
void	doesntRetainObjectsWithForcedErrorOnSubscriber_conditional()
void	doesntRetainObjectsWithForcedErrorOnSubscriber()
void	keyExtractorNull()
void	keyExtractorThrows()
void	scanConditionalSubscriber()
void	scanFuseableOperator()
void	scanFuseableSubscriber()
void	scanOperator()
void	scanSubscriber()
void	someDistinct()
void	someDistinctBackpressured()
void	sourceNull()
void	withKeyExtractorBackpressured()
void	withKeyExtractorSame()

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

构造器详细资料

FluxDistinctTest

public FluxDistinctTest()

方法详细资料

sourceNull

@Test
public void sourceNull()

keyExtractorNull

@Test
public void keyExtractorNull()

collectionSupplierNull

@Test
public void collectionSupplierNull()

collectionSupplierNullFuseable

@Test
public void collectionSupplierNullFuseable()

distinctPredicateNull

@Test
public void distinctPredicateNull()

cleanupNull

@Test
public void cleanupNull()

distinctCustomCollectionCustomPredicate

@Test
public void distinctCustomCollectionCustomPredicate()

allDistinct

@Test
public void allDistinct()

allDistinctBackpressured

@Test
public void allDistinctBackpressured()

allDistinctHide

@Test
public void allDistinctHide()

allDistinctBackpressuredHide

@Test
public void allDistinctBackpressuredHide()

someDistinct

@Test
public void someDistinct()

someDistinctBackpressured

@Test
public void someDistinctBackpressured()

allSame

@Test
public void allSame()

allSameFusable

@Test
public void allSameFusable()

allSameBackpressured

@Test
public void allSameBackpressured()

withKeyExtractorSame

@Test
public void withKeyExtractorSame()

withKeyExtractorBackpressured

@Test
public void withKeyExtractorBackpressured()

keyExtractorThrows

@Test
public void keyExtractorThrows()

collectionSupplierThrows

@Test
public void collectionSupplierThrows()

distinctPredicateThrows

@Test
public void distinctPredicateThrows()

distinctPredicateThrowsConditional

@Test
public void distinctPredicateThrowsConditional()

distinctPredicateThrowsConditionalOnNext

@Test
public void distinctPredicateThrowsConditionalOnNext()

collectionSupplierReturnsNull

@Test
public void collectionSupplierReturnsNull()

collectionSupplierLimitedFifo

@Test
public void collectionSupplierLimitedFifo()

scanOperator

@Test
public void scanOperator()

scanFuseableOperator

@Test
public void scanFuseableOperator()

scanSubscriber

@Test
public void scanSubscriber()

scanConditionalSubscriber

@Test
public void scanConditionalSubscriber()

scanFuseableSubscriber

@Test
public void scanFuseableSubscriber()

distinctDefaultWithHashcodeCollisions

@Test
public void distinctDefaultWithHashcodeCollisions()

distinctDefaultDoesntRetainObjects

@Test
public void distinctDefaultDoesntRetainObjects()
                                               throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

distinctDefaultErrorDoesntRetainObjects

@Test
public void distinctDefaultErrorDoesntRetainObjects()
                                                    throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

distinctDefaultCancelDoesntRetainObjects

@Test
public void distinctDefaultCancelDoesntRetainObjects()
                                                     throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

doesntRetainObjectsWithForcedCompleteOnSubscriber

@Test
public void doesntRetainObjectsWithForcedCompleteOnSubscriber()

doesntRetainObjectsWithForcedCompleteOnSubscriber_conditional

@Test
public void doesntRetainObjectsWithForcedCompleteOnSubscriber_conditional()

doesntRetainObjectsWithForcedErrorOnSubscriber

@Test
public void doesntRetainObjectsWithForcedErrorOnSubscriber()

doesntRetainObjectsWithForcedErrorOnSubscriber_conditional

@Test
public void doesntRetainObjectsWithForcedErrorOnSubscriber_conditional()

doesntRetainObjectsWithForcedCancelOnSubscriber

@Test
public void doesntRetainObjectsWithForcedCancelOnSubscriber()

doesntRetainObjectsWithForcedCancelOnSubscriber_conditional

@Test
public void doesntRetainObjectsWithForcedCancelOnSubscriber_conditional()