reactor.core.publisher

类 FluxUsingWhenTest

java.lang.Object

reactor.core.publisher.FluxUsingWhenTest

public class FluxUsingWhenTest
extends java.lang.Object

构造器概要

构造器

构造器和说明
FluxUsingWhenTest()

方法概要

限定符和类型	方法和说明
void	apiCancel(Flux<java.lang.String> transactionToCancel)
void	apiCommit(Flux<java.lang.String> fullTransaction)
void	apiCommitFailure(Flux<java.lang.String> fullTransaction)
void	apiRollback(Flux<java.lang.String> transactionWithError)
void	apiRollbackFailure(Flux<java.lang.String> transactionWithError)
void	apiRollbackGeneratingNull(Flux<java.lang.String> transactionWithError)
void	apiSingleAsyncCleanup() 已过时。
void	apiSingleAsyncCleanupFailure() 已过时。
void	blockOnNeverResourceCanBeCancelled()
void	cancelWithHandler(Flux<java.lang.String> source)
void	cancelWithoutHandlerAppliesCommit(Flux<java.lang.String> source) 已过时。
void	commitGeneratingNull(Flux<java.lang.String> fullTransaction)
void	contextPropagationOnCancel(Flux<java.lang.String> source)
void	contextPropagationOnCancelWithNoHandler(Flux<java.lang.String> source)
void	contextPropagationOnCommit(Mono<java.lang.String> source)
void	contextPropagationOnRollback(Mono<java.lang.String> source)
void	emptyResourceCallableDoesntApplyCallback()
void	emptyResourcePublisherDoesntApplyCallback()
void	errorCallbackReceivesCause()
void	errorResourceCallableDoesntApplyCallback()
void	errorResourcePublisherAfterEmitIsDropped()
void	errorResourcePublisherDoesntApplyCallback()
void	failToGenerateClosureAppliesRollback()
void	fluxResourcePublisherIsCancelled()
void	lateFluxResourcePublisherIsCancelledOnCancel()
void	lateMonoResourcePublisherIsCancelledOnCancel()
void	monoResourcePublisherIsNotCancelled()
void	noCancelCallbackAfterComplete()
void	noCancelCallbackAfterError()
void	noCompleteCallbackAfterCancel()
void	noErrorCallbackAfterCancel()
void	normalHasNoQueueOperations()
void	nullClosureAppliesRollback()
void	nullResourcePublisherRejected()
void	scanCancelInner()
void	scanCommitInner()
void	scanOperator()
void	scanResourceSubscriber()
void	scanRollbackInner()
void	scanUsingWhenSubscriber()
void	secondResourceInPublisherIsDropped()

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

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

构造器详细资料

FluxUsingWhenTest

public FluxUsingWhenTest()

方法详细资料

nullResourcePublisherRejected

@Test
public void nullResourcePublisherRejected()

emptyResourcePublisherDoesntApplyCallback

@Test
public void emptyResourcePublisherDoesntApplyCallback()

emptyResourceCallableDoesntApplyCallback

@Test
public void emptyResourceCallableDoesntApplyCallback()

errorResourcePublisherDoesntApplyCallback

@Test
public void errorResourcePublisherDoesntApplyCallback()

errorResourceCallableDoesntApplyCallback

@Test
public void errorResourceCallableDoesntApplyCallback()

errorResourcePublisherAfterEmitIsDropped

@Test
public void errorResourcePublisherAfterEmitIsDropped()

secondResourceInPublisherIsDropped

@Test
public void secondResourceInPublisherIsDropped()

fluxResourcePublisherIsCancelled

@Test
public void fluxResourcePublisherIsCancelled()

monoResourcePublisherIsNotCancelled

@Test
public void monoResourcePublisherIsNotCancelled()

lateFluxResourcePublisherIsCancelledOnCancel

@Test
public void lateFluxResourcePublisherIsCancelledOnCancel()

lateMonoResourcePublisherIsCancelledOnCancel

@Test
public void lateMonoResourcePublisherIsCancelledOnCancel()

blockOnNeverResourceCanBeCancelled

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

抛出:

java.lang.InterruptedException

failToGenerateClosureAppliesRollback

@Test
public void failToGenerateClosureAppliesRollback()

nullClosureAppliesRollback

@Test
public void nullClosureAppliesRollback()

cancelWithHandler

@MethodSource(value="sources01")
public void cancelWithHandler(Flux<java.lang.String> source)

cancelWithoutHandlerAppliesCommit

@MethodSource(value="sources01")
 @Deprecated
public void cancelWithoutHandlerAppliesCommit(Flux<java.lang.String> source)

已过时。

apiCommit

@MethodSource(value="sourcesFullTransaction")
public void apiCommit(Flux<java.lang.String> fullTransaction)

apiCommitFailure

@MethodSource(value="sourcesFullTransaction")
public void apiCommitFailure(Flux<java.lang.String> fullTransaction)

commitGeneratingNull

@MethodSource(value="sourcesFullTransaction")
public void commitGeneratingNull(Flux<java.lang.String> fullTransaction)

apiRollback

@MethodSource(value="sourcesTransactionError")
public void apiRollback(Flux<java.lang.String> transactionWithError)

apiRollbackFailure

@MethodSource(value="sourcesTransactionError")
public void apiRollbackFailure(Flux<java.lang.String> transactionWithError)

apiRollbackGeneratingNull

@MethodSource(value="sourcesTransactionError")
public void apiRollbackGeneratingNull(Flux<java.lang.String> transactionWithError)

apiCancel

@MethodSource(value="sourcesFullTransaction")
public void apiCancel(Flux<java.lang.String> transactionToCancel)

apiSingleAsyncCleanup

@Test
 @Deprecated
public void apiSingleAsyncCleanup()

已过时。

apiSingleAsyncCleanupFailure

@Test
 @Deprecated
public void apiSingleAsyncCleanupFailure()

已过时。

normalHasNoQueueOperations

@Test
public void normalHasNoQueueOperations()

contextPropagationOnCommit

@MethodSource(value="sourcesContext")
public void contextPropagationOnCommit(Mono<java.lang.String> source)

contextPropagationOnRollback

@MethodSource(value="sourcesContextError")
public void contextPropagationOnRollback(Mono<java.lang.String> source)

contextPropagationOnCancel

@MethodSource(value="sources01")
public void contextPropagationOnCancel(Flux<java.lang.String> source)

contextPropagationOnCancelWithNoHandler

@MethodSource(value="sources01")
public void contextPropagationOnCancelWithNoHandler(Flux<java.lang.String> source)

noCancelCallbackAfterComplete

@Test
public void noCancelCallbackAfterComplete()

noCancelCallbackAfterError

@Test
public void noCancelCallbackAfterError()

noCompleteCallbackAfterCancel

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

抛出:

java.lang.InterruptedException

noErrorCallbackAfterCancel

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

抛出:

java.lang.InterruptedException

errorCallbackReceivesCause

@Test
public void errorCallbackReceivesCause()

scanOperator

@Test
public void scanOperator()

scanResourceSubscriber

@Test
public void scanResourceSubscriber()

scanUsingWhenSubscriber

@Test
public void scanUsingWhenSubscriber()

scanCommitInner

@Test
public void scanCommitInner()

scanRollbackInner

@Test
public void scanRollbackInner()

scanCancelInner

@Test
public void scanCancelInner()