reactor.core.publisher

类 FluxRetryWhenTest

java.lang.Object

reactor.core.publisher.FluxRetryWhenTest

public class FluxRetryWhenTest
extends java.lang.Object

构造器概要

构造器

构造器和说明
FluxRetryWhenTest()

方法概要

限定符和类型	方法和说明
void	backoffFunctionNotTransient()
void	backoffFunctionTransient()
void	cancelsOther()
void	cancelTwiceCancelsOtherOnce()
void	coldEmpty()
void	coldError()
void	coldRepeater()
void	coldRepeaterBackpressured()
void	directOtherEmptyPreventsSubscribeAndCompletes()
void	directOtherErrorPreventsSubscribe()
void	dontRepeat()
void	fixedDelaysRetry()
void	fluxRetryBackoffRetriesOnGivenScheduler()
void	fluxRetryBackoffWithSpecificScheduler()
void	fluxRetryRandomBackoff_maxBackoffShaves()
void	fluxRetryRandomBackoff_minBackoffFloor()
void	fluxRetryRandomBackoff_noRandomness()
void	fluxRetryRandomBackoff()
void	fluxRetryRandomBackoffDefaultJitter()
void	fluxRetryRandomBackoffDefaultMaxDuration()
void	fluxRetryRandomBackoffNoArithmeticException()
void	gh1978()
void	inners()
void	lateOtherEmptyCancelsSourceAndCompletes()
void	lateOtherErrorCancelsSource()
void	linearRetry()
void	predicateThrows()
void	retryAlways()
void	retryContextExposedOnRetrySignal()
void	retryErrorsInResponse()
void	retryWhenContextTrigger_MergesOriginalContext()
void	retryWhenThrowableCompanionIsComparableToRetryWhenRetryFromFunction()
void	retryWhenWithThrowableFunction()
void	scanMainSubscriber()
void	scanOperator()
void	scanOtherSubscriber()
void	shouldFailWhenOnErrorContinueEnabled()
void	shouldWorkAsExpected()
void	simpleFunctionTransient()
void	sourceNull()
static Flux<java.lang.Integer>	transientErrorSource()
void	twoRetryErrorSupplier()
void	twoRetryErrorSupplier2()
void	twoRetryNormal()
void	twoRetryNormalSupplier()
void	twoRetryNormalSupplier2()
void	twoRetryNormalSupplier3()
void	whenFactoryReturnsNull()
void	whenFactoryThrows()
void	whenRetrySignalFactoryNull()

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

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

构造器详细资料

FluxRetryWhenTest

public FluxRetryWhenTest()

方法详细资料

shouldFailWhenOnErrorContinueEnabled

@Test
public void shouldFailWhenOnErrorContinueEnabled()

shouldWorkAsExpected

@Test
public void shouldWorkAsExpected()

dontRepeat

@Test
public void dontRepeat()

predicateThrows

@Test
public void predicateThrows()

twoRetryNormal

@Test
public void twoRetryNormal()

twoRetryNormalSupplier

@Test
public void twoRetryNormalSupplier()

twoRetryErrorSupplier

@Test
public void twoRetryErrorSupplier()

twoRetryNormalSupplier3

@Test
public void twoRetryNormalSupplier3()

twoRetryNormalSupplier2

@Test
public void twoRetryNormalSupplier2()

twoRetryErrorSupplier2

@Test
public void twoRetryErrorSupplier2()

sourceNull

@Test
public void sourceNull()

whenRetrySignalFactoryNull

@Test
public void whenRetrySignalFactoryNull()

cancelsOther

@Test
public void cancelsOther()

cancelTwiceCancelsOtherOnce

@Test
public void cancelTwiceCancelsOtherOnce()

directOtherErrorPreventsSubscribe

@Test
public void directOtherErrorPreventsSubscribe()

lateOtherErrorCancelsSource

@Test
public void lateOtherErrorCancelsSource()

directOtherEmptyPreventsSubscribeAndCompletes

@Test
public void directOtherEmptyPreventsSubscribeAndCompletes()

lateOtherEmptyCancelsSourceAndCompletes

@Test
public void lateOtherEmptyCancelsSourceAndCompletes()

coldRepeater

@Test
public void coldRepeater()

coldRepeaterBackpressured

@Test
public void coldRepeaterBackpressured()

coldEmpty

@Test
public void coldEmpty()

coldError

@Test
public void coldError()

whenFactoryThrows

@Test
public void whenFactoryThrows()

whenFactoryReturnsNull

@Test
public void whenFactoryReturnsNull()

retryErrorsInResponse

@Test
public void retryErrorsInResponse()

retryAlways

@Test
public void retryAlways()

linearRetry

@Test
public void linearRetry()

fixedDelaysRetry

@Test
public void fixedDelaysRetry()

scanOperator

@Test
public void scanOperator()

scanMainSubscriber

@Test
public void scanMainSubscriber()

scanOtherSubscriber

@Test
public void scanOtherSubscriber()

inners

@Test
public void inners()

retryContextExposedOnRetrySignal

@Test
public void retryContextExposedOnRetrySignal()

retryWhenContextTrigger_MergesOriginalContext

@Test
public void retryWhenContextTrigger_MergesOriginalContext()

fluxRetryRandomBackoff

@Test
public void fluxRetryRandomBackoff()

fluxRetryRandomBackoffDefaultJitter

@Test
public void fluxRetryRandomBackoffDefaultJitter()

fluxRetryRandomBackoffDefaultMaxDuration

@Test
public void fluxRetryRandomBackoffDefaultMaxDuration()

fluxRetryRandomBackoff_maxBackoffShaves

@Test
public void fluxRetryRandomBackoff_maxBackoffShaves()

fluxRetryRandomBackoff_minBackoffFloor

@Test
public void fluxRetryRandomBackoff_minBackoffFloor()

fluxRetryRandomBackoff_noRandomness

@Test
public void fluxRetryRandomBackoff_noRandomness()

fluxRetryRandomBackoffNoArithmeticException

@Test
public void fluxRetryRandomBackoffNoArithmeticException()

fluxRetryBackoffWithSpecificScheduler

@Test
public void fluxRetryBackoffWithSpecificScheduler()

fluxRetryBackoffRetriesOnGivenScheduler

@Test
public void fluxRetryBackoffRetriesOnGivenScheduler()

backoffFunctionNotTransient

@Test
public void backoffFunctionNotTransient()

backoffFunctionTransient

@Test
public void backoffFunctionTransient()

simpleFunctionTransient

@Test
public void simpleFunctionTransient()

gh1978

@Test
public void gh1978()

transientErrorSource

public static Flux<java.lang.Integer> transientErrorSource()

retryWhenThrowableCompanionIsComparableToRetryWhenRetryFromFunction

@Test
public void retryWhenThrowableCompanionIsComparableToRetryWhenRetryFromFunction()

retryWhenWithThrowableFunction

@Test
public void retryWhenWithThrowableFunction()