reactor.core.publisher

类 FluxPeekFuseableTest

java.lang.Object

reactor.core.publisher.FluxPeekFuseableTest

public class FluxPeekFuseableTest
extends java.lang.Object

构造器概要

构造器

构造器和说明
FluxPeekFuseableTest()

方法概要

限定符和类型	方法和说明
void	afterTerminateCallbackFatalIsThrownDirectly()
void	asyncFusionAvailable()
void	callbackError()
void	completeCallbackError()
void	conditionalFusedDoOnNextCallsOnErrorWhenFailing()
void	conditionalFusedDoOnNextOnErrorBothFailing()
void	conditionalFusedDoOnNextOnErrorDoOnErrorAllFailing()
void	conditionalFusionAvailable()
void	conditionalFusionAvailableWithFuseable()
void	empty()
void	error()
void	errorCallbackError()
void	errorCallbackError2()
void	errorCallbackErrorWithParallel()
void	fusedDoOnNextCallsOnErrorWhenFailing()
void	fusedDoOnNextOnErrorBothFailing()
void	fusedDoOnNextOnErrorDoOnErrorAllFailing()
void	never()
void	neverCancel()
void	noFusionAfterTerminateCalled()
void	noFusionCompleteCalled()
void	normal()
void	nullSource()
void	resumeConditional()
void	resumeFuseable()
void	resumeFuseableConditional()
void	scanFuseableConditionalSubscriber()
void	scanFuseableSubscriber()
void	scanOperator()
void	should_reduce_to_10_events_conditional()
void	should_reduce_to_10_events()
void	syncFusionAvailable()
void	syncPollAfterTerminateCalledWhenComplete()
void	syncPollAfterTerminateCalledWhenError()
void	syncPollAfterTerminateFailureWhenError()
void	syncPollCompleteCalled()
void	syncPollConditionalAfterTerminateCalledWhenComplete()
void	syncPollConditionalAfterTerminateCalledWhenError()
void	syncPollConditionalAfterTerminateFailureWhenError()
void	syncPollConditionalCompleteCalled()

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

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

构造器详细资料

FluxPeekFuseableTest

public FluxPeekFuseableTest()

方法详细资料

nullSource

@Test
public void nullSource()

normal

@Test
public void normal()

error

@Test
public void error()

empty

@Test
public void empty()

never

@Test
public void never()

neverCancel

@Test
public void neverCancel()

callbackError

@Test
public void callbackError()

completeCallbackError

@Test
public void completeCallbackError()

errorCallbackError

@Test
public void errorCallbackError()

errorCallbackError2

@Test
public void errorCallbackError2()

errorCallbackErrorWithParallel

@Test
public void errorCallbackErrorWithParallel()

afterTerminateCallbackFatalIsThrownDirectly

@Test
public void afterTerminateCallbackFatalIsThrownDirectly()

syncFusionAvailable

@Test
public void syncFusionAvailable()

asyncFusionAvailable

@Test
public void asyncFusionAvailable()

conditionalFusionAvailable

@Test
public void conditionalFusionAvailable()

conditionalFusionAvailableWithFuseable

@Test
public void conditionalFusionAvailableWithFuseable()

noFusionCompleteCalled

@Test
public void noFusionCompleteCalled()

noFusionAfterTerminateCalled

@Test
public void noFusionAfterTerminateCalled()

syncPollCompleteCalled

@Test
public void syncPollCompleteCalled()

syncPollConditionalCompleteCalled

@Test
public void syncPollConditionalCompleteCalled()

syncPollAfterTerminateCalledWhenComplete

@Test
public void syncPollAfterTerminateCalledWhenComplete()

syncPollConditionalAfterTerminateCalledWhenComplete

@Test
public void syncPollConditionalAfterTerminateCalledWhenComplete()

syncPollAfterTerminateCalledWhenError

@Test
public void syncPollAfterTerminateCalledWhenError()

syncPollConditionalAfterTerminateCalledWhenError

@Test
public void syncPollConditionalAfterTerminateCalledWhenError()

syncPollAfterTerminateFailureWhenError

@Test
public void syncPollAfterTerminateFailureWhenError()

syncPollConditionalAfterTerminateFailureWhenError

@Test
public void syncPollConditionalAfterTerminateFailureWhenError()

fusedDoOnNextOnErrorBothFailing

@Test
public void fusedDoOnNextOnErrorBothFailing()

fusedDoOnNextOnErrorDoOnErrorAllFailing

@Test
public void fusedDoOnNextOnErrorDoOnErrorAllFailing()

fusedDoOnNextCallsOnErrorWhenFailing

@Test
public void fusedDoOnNextCallsOnErrorWhenFailing()

conditionalFusedDoOnNextOnErrorBothFailing

@Test
public void conditionalFusedDoOnNextOnErrorBothFailing()

conditionalFusedDoOnNextOnErrorDoOnErrorAllFailing

@Test
public void conditionalFusedDoOnNextOnErrorDoOnErrorAllFailing()

conditionalFusedDoOnNextCallsOnErrorWhenFailing

@Test
public void conditionalFusedDoOnNextCallsOnErrorWhenFailing()

should_reduce_to_10_events

@Test
public void should_reduce_to_10_events()

should_reduce_to_10_events_conditional

@Test
public void should_reduce_to_10_events_conditional()

scanOperator

@Test
public void scanOperator()

scanFuseableSubscriber

@Test
public void scanFuseableSubscriber()

scanFuseableConditionalSubscriber

@Test
public void scanFuseableConditionalSubscriber()

resumeConditional

@Test
public void resumeConditional()

resumeFuseable

@Test
public void resumeFuseable()

resumeFuseableConditional

@Test
public void resumeFuseableConditional()