reactor.core.publisher

类 FluxDistinctUntilChangedTest

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

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

嵌套类概要

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

FluxOperatorTest.Scenario<I,O>

构造器概要

构造器

构造器和说明
FluxDistinctUntilChangedTest()

方法概要

限定符和类型	方法和说明
void	allDistinct()
void	allDistinctBackpressured()
void	allDistinctConditional()
void	distinctUntilChangedDefaultCancelDoesntRetainObjects()
void	distinctUntilChangedDefaultDoesntRetainObjects()
void	distinctUntilChangedDefaultErrorDoesntRetainObjects()
void	distinctUntilChangedDefaultWithHashcodeCollisions()
void	doesntRetainObjectsWithForcedCancelOnSubscriber_conditional()
void	doesntRetainObjectsWithForcedCancelOnSubscriber()
void	doesntRetainObjectsWithForcedCompleteOnSubscriber_conditional()
void	doesntRetainObjectsWithForcedCompleteOnSubscriber()
void	doesntRetainObjectsWithForcedErrorOnSubscriber_conditional()
void	doesntRetainObjectsWithForcedErrorOnSubscriber()
void	keyComparatorThrows()
void	keyExtractorNull()
void	keySelectorThrows()
void	predicateNull()
void	scanConditionalSubscriber()
void	scanOperator()
void	scanSubscriber()
void	someRepetition()
void	someRepetitionBackpressured()
void	sourceNull()
void	withKeyComparator()
void	withKeySelector()

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

构造器详细资料

FluxDistinctUntilChangedTest

public FluxDistinctUntilChangedTest()

方法详细资料

sourceNull

@Test
public void sourceNull()

keyExtractorNull

@Test
public void keyExtractorNull()

predicateNull

@Test
public void predicateNull()

allDistinct

@Test
public void allDistinct()

allDistinctBackpressured

@Test
public void allDistinctBackpressured()

someRepetition

@Test
public void someRepetition()

someRepetitionBackpressured

@Test
public void someRepetitionBackpressured()

withKeySelector

@Test
public void withKeySelector()

withKeyComparator

@Test
public void withKeyComparator()

keySelectorThrows

@Test
public void keySelectorThrows()

keyComparatorThrows

@Test
public void keyComparatorThrows()

allDistinctConditional

@Test
public void allDistinctConditional()

scanOperator

@Test
public void scanOperator()

scanSubscriber

@Test
public void scanSubscriber()

scanConditionalSubscriber

@Test
public void scanConditionalSubscriber()

distinctUntilChangedDefaultWithHashcodeCollisions

@Test
public void distinctUntilChangedDefaultWithHashcodeCollisions()

distinctUntilChangedDefaultDoesntRetainObjects

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

抛出:

java.lang.InterruptedException

distinctUntilChangedDefaultErrorDoesntRetainObjects

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

抛出:

java.lang.InterruptedException

distinctUntilChangedDefaultCancelDoesntRetainObjects

@Test
public void distinctUntilChangedDefaultCancelDoesntRetainObjects()
                                                                 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()