reactor.core.publisher

类 FluxSwitchOnFirstTest

java.lang.Object

reactor.core.publisher.FluxSwitchOnFirstTest

public class FluxSwitchOnFirstTest
extends java.lang.Object

构造器概要

构造器

构造器和说明
FluxSwitchOnFirstTest()

方法概要

限定符和类型	方法和说明
void	backpressureConditionalTest()
void	backpressureDrawbackOnConditionalInTransformTest()
void	backpressureHiddenConditionalTest()
void	backpressureTest()
void	checkHotSource()
void	scanConditionnalSubscriber()
void	scanMain()
void	scanMainConditional()
void	scanOperator()
void	scanSubscriber()
void	shouldBeAbleToBeCancelledProperly()
void	shouldBeAbleToBeCancelledProperly2()
void	shouldBeAbleToBeCancelledProperly3()
void	shouldBeAbleToCatchDiscardedElement()
void	shouldBeAbleToCatchDiscardedElementInCaseOfConditional()
void	shouldBeRequestedExactlyOneAndThenLongMaxValue()
void	shouldBeRequestedExactlyOneAndThenLongMaxValueConditional()
void	shouldBeRequestedOneFromUpstreamTwiceInCaseOfConditional()
void	shouldCancelInnerSubscriptionImmediatelyUpOnReceivingIfDownstreamIsAlreadyCancelled()
void	shouldCancelInnerSubscriptionImmediatelyUpOnReceivingIfDownstreamIsAlreadyCancelledConditional()
void	shouldCancelSourceOnOnDownstreamTerminal()
void	shouldCancelSourceOnUnrelatedPublisherCancel()
void	shouldCancelSourceOnUnrelatedPublisherCancelConditional()
void	shouldCancelSourceOnUnrelatedPublisherComplete()
void	shouldCancelSourceOnUnrelatedPublisherCompleteConditional()
void	shouldCancelSourceOnUnrelatedPublisherError()
void	shouldCancelSourceOnUnrelatedPublisherErrorConditional()
void	shouldCancelUpstreamBeforeFirst()
void	shouldContinueWorkingRegardlessTerminalOnDownstream()
void	shouldErrorOnOverflowTest()
void	shouldNeverSendIncorrectRequestSizeToUpstream()
void	shouldNeverSendIncorrectRequestSizeToUpstreamConditional()
void	shouldNotBeAbleToAccessUpstreamContext()
void	shouldNotCancelSourceOnUnrelatedPublisherComplete()
void	shouldNotCancelSourceOnUnrelatedPublisherCompleteConditional()
void	shouldNotFailOnIncorrectPublisherBehavior()
void	shouldNotHangWhenOneElementUpstream()
void	shouldNotSubscribeTwice()
void	shouldNotSubscribeTwiceConditional()
void	shouldNotSubscribeTwiceConditionalWhenCanceled()
void	shouldNotSubscribeTwiceWhenCanceled()
void	shouldPropagateErrorCorrectly()
void	shouldPropagateonCompleteCorrectly()
void	shouldPropagateOnCompleteWithMergedElementsCorrectly()
void	shouldReturnCorrectContextIfLoosingChain()
void	shouldReturnCorrectContextOnEmptySource()
void	shouldReturnNormallyIfExceptionIsThrownOnCompleteDuringSwitching()
void	shouldReturnNormallyIfExceptionIsThrownOnCompleteDuringSwitchingConditional()
void	shouldReturnNormallyIfExceptionIsThrownOnErrorDuringSwitching()
void	shouldReturnNormallyIfExceptionIsThrownOnErrorDuringSwitchingConditional()
void	shouldReturnNormallyIfExceptionIsThrownOnNextDuringSwitching()
void	shouldReturnNormallyIfExceptionIsThrownOnNextDuringSwitchingConditional()
void	shouldSendOnCompleteSignalWithDelaySubscription()
void	shouldSendOnErrorSignal()
void	shouldSendOnErrorSignalConditional()
void	shouldSendOnErrorSignalWithDelaySubscription()
void	shouldSendOnNextAsyncSignal()
void	shouldSendOnNextAsyncSignalConditional()
void	shouldSendOnNextSignal()
void	shouldSendOnNextSignalConditional()
void	sourceSubscribedOnce()

从类继承的方法 java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

FluxSwitchOnFirstTest

public FluxSwitchOnFirstTest()

方法详细资料

shouldNotSubscribeTwice

@Test
public void shouldNotSubscribeTwice()

shouldNotSubscribeTwiceConditional

@Test
public void shouldNotSubscribeTwiceConditional()

shouldNotSubscribeTwiceWhenCanceled

@Test
public void shouldNotSubscribeTwiceWhenCanceled()

shouldNotSubscribeTwiceConditionalWhenCanceled

@Test
public void shouldNotSubscribeTwiceConditionalWhenCanceled()

shouldSendOnErrorSignalConditional

@Test
public void shouldSendOnErrorSignalConditional()

shouldSendOnNextSignalConditional

@Test
public void shouldSendOnNextSignalConditional()

shouldSendOnErrorSignalWithDelaySubscription

@Test
public void shouldSendOnErrorSignalWithDelaySubscription()

shouldSendOnCompleteSignalWithDelaySubscription

@Test
public void shouldSendOnCompleteSignalWithDelaySubscription()

shouldSendOnErrorSignal

@Test
public void shouldSendOnErrorSignal()

shouldSendOnNextSignal

@Test
public void shouldSendOnNextSignal()

shouldSendOnNextAsyncSignal

@Test
public void shouldSendOnNextAsyncSignal()

shouldSendOnNextAsyncSignalConditional

@Test
public void shouldSendOnNextAsyncSignalConditional()

shouldNeverSendIncorrectRequestSizeToUpstream

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

抛出:

java.lang.InterruptedException

shouldNeverSendIncorrectRequestSizeToUpstreamConditional

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

抛出:

java.lang.InterruptedException

shouldBeRequestedOneFromUpstreamTwiceInCaseOfConditional

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

抛出:

java.lang.InterruptedException

shouldBeRequestedExactlyOneAndThenLongMaxValue

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

抛出:

java.lang.InterruptedException

shouldBeRequestedExactlyOneAndThenLongMaxValueConditional

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

抛出:

java.lang.InterruptedException

shouldReturnCorrectContextOnEmptySource

@Test
public void shouldReturnCorrectContextOnEmptySource()

shouldReturnCorrectContextIfLoosingChain

@Test
public void shouldReturnCorrectContextIfLoosingChain()

shouldNotFailOnIncorrectPublisherBehavior

@Test
public void shouldNotFailOnIncorrectPublisherBehavior()

shouldNotBeAbleToAccessUpstreamContext

@Test
public void shouldNotBeAbleToAccessUpstreamContext()

shouldNotHangWhenOneElementUpstream

@Test
public void shouldNotHangWhenOneElementUpstream()

backpressureTest

@Test
public void backpressureTest()

backpressureConditionalTest

@Test
public void backpressureConditionalTest()

backpressureHiddenConditionalTest

@Test
public void backpressureHiddenConditionalTest()

backpressureDrawbackOnConditionalInTransformTest

@Test
public void backpressureDrawbackOnConditionalInTransformTest()

shouldErrorOnOverflowTest

@Test
public void shouldErrorOnOverflowTest()

shouldPropagateonCompleteCorrectly

@Test
public void shouldPropagateonCompleteCorrectly()

shouldPropagateOnCompleteWithMergedElementsCorrectly

@Test
public void shouldPropagateOnCompleteWithMergedElementsCorrectly()

shouldPropagateErrorCorrectly

@Test
public void shouldPropagateErrorCorrectly()

shouldBeAbleToBeCancelledProperly

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

抛出:

java.lang.InterruptedException

shouldBeAbleToBeCancelledProperly2

@Test
public void shouldBeAbleToBeCancelledProperly2()

shouldBeAbleToBeCancelledProperly3

@Test
public void shouldBeAbleToBeCancelledProperly3()

shouldBeAbleToCatchDiscardedElement

@Test
public void shouldBeAbleToCatchDiscardedElement()

shouldBeAbleToCatchDiscardedElementInCaseOfConditional

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

抛出:

java.lang.InterruptedException

shouldReturnNormallyIfExceptionIsThrownOnNextDuringSwitching

@Test
public void shouldReturnNormallyIfExceptionIsThrownOnNextDuringSwitching()

shouldReturnNormallyIfExceptionIsThrownOnErrorDuringSwitching

@Test
public void shouldReturnNormallyIfExceptionIsThrownOnErrorDuringSwitching()

shouldReturnNormallyIfExceptionIsThrownOnCompleteDuringSwitching

@Test
public void shouldReturnNormallyIfExceptionIsThrownOnCompleteDuringSwitching()

shouldReturnNormallyIfExceptionIsThrownOnNextDuringSwitchingConditional

@Test
public void shouldReturnNormallyIfExceptionIsThrownOnNextDuringSwitchingConditional()

shouldReturnNormallyIfExceptionIsThrownOnErrorDuringSwitchingConditional

@Test
public void shouldReturnNormallyIfExceptionIsThrownOnErrorDuringSwitchingConditional()

shouldReturnNormallyIfExceptionIsThrownOnCompleteDuringSwitchingConditional

@Test
public void shouldReturnNormallyIfExceptionIsThrownOnCompleteDuringSwitchingConditional()

sourceSubscribedOnce

@Test
public void sourceSubscribedOnce()

checkHotSource

@Test
public void checkHotSource()

shouldCancelSourceOnUnrelatedPublisherComplete

@Test
public void shouldCancelSourceOnUnrelatedPublisherComplete()

shouldNotCancelSourceOnUnrelatedPublisherComplete

@Test
public void shouldNotCancelSourceOnUnrelatedPublisherComplete()

shouldCancelSourceOnUnrelatedPublisherError

@Test
public void shouldCancelSourceOnUnrelatedPublisherError()

shouldCancelSourceOnUnrelatedPublisherCancel

@Test
public void shouldCancelSourceOnUnrelatedPublisherCancel()

shouldCancelSourceOnUnrelatedPublisherCompleteConditional

@Test
public void shouldCancelSourceOnUnrelatedPublisherCompleteConditional()

shouldNotCancelSourceOnUnrelatedPublisherCompleteConditional

@Test
public void shouldNotCancelSourceOnUnrelatedPublisherCompleteConditional()

shouldCancelInnerSubscriptionImmediatelyUpOnReceivingIfDownstreamIsAlreadyCancelledConditional

@Test
public void shouldCancelInnerSubscriptionImmediatelyUpOnReceivingIfDownstreamIsAlreadyCancelledConditional()

shouldCancelInnerSubscriptionImmediatelyUpOnReceivingIfDownstreamIsAlreadyCancelled

@Test
public void shouldCancelInnerSubscriptionImmediatelyUpOnReceivingIfDownstreamIsAlreadyCancelled()

shouldCancelSourceOnUnrelatedPublisherErrorConditional

@Test
public void shouldCancelSourceOnUnrelatedPublisherErrorConditional()

shouldCancelSourceOnUnrelatedPublisherCancelConditional

@Test
public void shouldCancelSourceOnUnrelatedPublisherCancelConditional()

shouldCancelUpstreamBeforeFirst

@Test
public void shouldCancelUpstreamBeforeFirst()

shouldContinueWorkingRegardlessTerminalOnDownstream

@Test
public void shouldContinueWorkingRegardlessTerminalOnDownstream()

shouldCancelSourceOnOnDownstreamTerminal

@Test
public void shouldCancelSourceOnOnDownstreamTerminal()

scanOperator

@Test
public void scanOperator()

scanMain

@Test
public void scanMain()

scanMainConditional

@Test
public void scanMainConditional()

scanSubscriber

@Test
public void scanSubscriber()

scanConditionnalSubscriber

@Test
public void scanConditionnalSubscriber()