reactor.guide

类 GuideTests

java.lang.Object

reactor.guide.GuideTests

public class GuideTests
extends java.lang.Object

Tests mirroring snippets from the reference documentation.

作者:

Stephane Maldini, Simon Baslé

字段概要

字段

限定符和类型	字段和说明
Mono<java.lang.String>	toDebug

构造器概要

构造器

构造器和说明
GuideTests()

方法概要

限定符和类型	方法和说明
void	advancedBatchingBuffering()
void	advancedBatchingBufferingSizeOverlap()
void	advancedBatchingGrouping()
void	advancedBatchingWindowing()
void	advancedBatchingWindowingSizeOverlap()
void	advancedCold()
void	advancedComposedDefer()
void	advancedComposedNow()
void	advancedConnectable()
void	advancedConnectableAutoConnect()
void	advancedHot()
void	advancedParallelJustDivided()
void	advancedParallelParallelized()
java.lang.String	alphabet(int letterNumber)
void	baseSubscriberFineTuneBackpressure()
void	contextForLibraryReactivePut()
void	contextForLibraryReactivePutNoContext()
void	contextSimple1()
void	contextSimple2()
void	contextSimple4()
void	contextSimple5()
void	contextSimple6()
java.lang.String	convert(int i)
void	debuggingActivated()
void	debuggingCommonStacktrace()
void	debuggingLogging()
void	errorHandlingDoFinally()
void	errorHandlingIntervalMillisNotContinued()
void	errorHandlingIntervalMillisRetried()
void	errorHandlingOnError()
void	errorHandlingOnErrorResume()
void	errorHandlingOnErrorResumeDependingOnError()
void	errorHandlingPropagateUnwrap()
void	errorHandlingRethrow1()
void	errorHandlingRethrow2()
void	errorHandlingRetryBuilders()
void	errorHandlingRetryWhenApproximateRetry()
void	errorHandlingRetryWhenEquatesRetry()
void	errorHandlingRetryWhenExponential()
void	errorHandlingRetryWhenTransient()
void	errorHandlingReturn()
void	errorHandlingReturnFilter()
void	errorHandlingSideEffect()
void	errorHandlingTryCatch()
void	errorHandlingUsing()
void	introFutureHell()
void	introFutureHellReactorVersion()
void	populateDebug(org.junit.jupiter.api.TestInfo testInfo)
Mono<java.lang.Void>	processOrFallback(Mono<java.lang.String> commandSource, Mono<java.lang.Void> doWhenEmpty)
Flux<java.lang.String>	processOrFallback(Mono<java.lang.String> source, org.reactivestreams.Publisher<java.lang.String> fallback)
void	producingCreate()
void	producingGenerate()
void	producingGenerateMutableState()
void	producingHandle()
void	removeHooks(org.junit.jupiter.api.TestInfo testInfo)
void	testCommandEmptyPathIsUsed()
void	testCommandEmptyPathIsUsedBoilerplate()
void	testEmptyPathIsUsed()
void	testSplitPathIsUsed()

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

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

字段详细资料

toDebug

public Mono<java.lang.String> toDebug

构造器详细资料

GuideTests

public GuideTests()

方法详细资料

introFutureHell

@Test
public void introFutureHell()

introFutureHellReactorVersion

@Test
public void introFutureHellReactorVersion()

advancedComposedNow

@Test
public void advancedComposedNow()

advancedComposedDefer

@Test
public void advancedComposedDefer()

advancedCold

@Test
public void advancedCold()

advancedHot

@Test
public void advancedHot()

advancedConnectable

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

抛出:

java.lang.InterruptedException

advancedConnectableAutoConnect

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

抛出:

java.lang.InterruptedException

advancedBatchingGrouping

@Test
public void advancedBatchingGrouping()

advancedBatchingWindowingSizeOverlap

@Test
public void advancedBatchingWindowingSizeOverlap()

advancedBatchingWindowing

@Test
public void advancedBatchingWindowing()

advancedBatchingBufferingSizeOverlap

@Test
public void advancedBatchingBufferingSizeOverlap()

advancedBatchingBuffering

@Test
public void advancedBatchingBuffering()

advancedParallelJustDivided

@Test
public void advancedParallelJustDivided()

advancedParallelParallelized

@Test
public void advancedParallelParallelized()

baseSubscriberFineTuneBackpressure

@Test
public void baseSubscriberFineTuneBackpressure()

errorHandlingOnError

@Test
public void errorHandlingOnError()

errorHandlingTryCatch

@Test
public void errorHandlingTryCatch()

errorHandlingReturn

@Test
public void errorHandlingReturn()

errorHandlingReturnFilter

@Test
public void errorHandlingReturnFilter()

errorHandlingOnErrorResume

@Test
public void errorHandlingOnErrorResume()

errorHandlingOnErrorResumeDependingOnError

@Test
public void errorHandlingOnErrorResumeDependingOnError()

errorHandlingRethrow1

@Test
public void errorHandlingRethrow1()

errorHandlingRethrow2

@Test
public void errorHandlingRethrow2()

errorHandlingSideEffect

@Test
public void errorHandlingSideEffect()

errorHandlingUsing

@Test
public void errorHandlingUsing()

errorHandlingDoFinally

@Test
public void errorHandlingDoFinally()

errorHandlingIntervalMillisNotContinued

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

抛出:

java.lang.InterruptedException

errorHandlingIntervalMillisRetried

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

抛出:

java.lang.InterruptedException

errorHandlingRetryWhenApproximateRetry

@Test
public void errorHandlingRetryWhenApproximateRetry()

errorHandlingRetryWhenEquatesRetry

@Test
public void errorHandlingRetryWhenEquatesRetry()

errorHandlingRetryBuilders

@Test
public void errorHandlingRetryBuilders()

errorHandlingRetryWhenExponential

@Test
public void errorHandlingRetryWhenExponential()

errorHandlingRetryWhenTransient

@Test
public void errorHandlingRetryWhenTransient()

convert

public java.lang.String convert(int i)
                         throws java.io.IOException

抛出:

java.io.IOException

errorHandlingPropagateUnwrap

@Test
public void errorHandlingPropagateUnwrap()

producingGenerate

@Test
public void producingGenerate()

producingGenerateMutableState

@Test
public void producingGenerateMutableState()

producingCreate

@Test
public void producingCreate()

alphabet

public java.lang.String alphabet(int letterNumber)

producingHandle

@Test
public void producingHandle()

processOrFallback

public Flux<java.lang.String> processOrFallback(Mono<java.lang.String> source,
                                                org.reactivestreams.Publisher<java.lang.String> fallback)

testSplitPathIsUsed

@Test
public void testSplitPathIsUsed()

testEmptyPathIsUsed

@Test
public void testEmptyPathIsUsed()

processOrFallback

public Mono<java.lang.Void> processOrFallback(Mono<java.lang.String> commandSource,
                                              Mono<java.lang.Void> doWhenEmpty)

testCommandEmptyPathIsUsedBoilerplate

@Test
public void testCommandEmptyPathIsUsedBoilerplate()

testCommandEmptyPathIsUsed

@Test
public void testCommandEmptyPathIsUsed()

populateDebug

@BeforeEach
public void populateDebug(org.junit.jupiter.api.TestInfo testInfo)

removeHooks

@AfterEach
public void removeHooks(org.junit.jupiter.api.TestInfo testInfo)

debuggingCommonStacktrace

@Test
 @Tag(value="debugInit")
public void debuggingCommonStacktrace()

debuggingActivated

@Test
 @Tag(value="debugModeOn") @Tag(value="debugInit")
public void debuggingActivated()

debuggingLogging

@Test
public void debuggingLogging()

contextSimple1

@Test
public void contextSimple1()

contextSimple2

@Test
public void contextSimple2()

contextSimple4

@Test
public void contextSimple4()

contextSimple5

@Test
public void contextSimple5()

contextSimple6

@Test
public void contextSimple6()

contextForLibraryReactivePut

@Test
public void contextForLibraryReactivePut()

contextForLibraryReactivePutNoContext

@Test
public void contextForLibraryReactivePutNoContext()