reactor.core.publisher

类 FluxSwitchOnFirstStressTest.OutboundCancelAndInboundCancelStressTest

java.lang.Object

reactor.core.publisher.FluxSwitchOnFirstStressTest

reactor.core.publisher.FluxSwitchOnFirstStressTest.OutboundCancelAndInboundCancelStressTest

封闭类:

FluxSwitchOnFirstStressTest

public static class FluxSwitchOnFirstStressTest.OutboundCancelAndInboundCancelStressTest
extends FluxSwitchOnFirstStressTest

嵌套类概要

从类继承的嵌套类/接口 reactor.core.publisher.FluxSwitchOnFirstStressTest

FluxSwitchOnFirstStressTest.InboundCompleteLeadingToErrorAndOutboundCancelStressTest, FluxSwitchOnFirstStressTest.InboundErrorLeadingToErrorAndOutboundCancelStressTest, FluxSwitchOnFirstStressTest.InboundNextLeadingToErrorAndOutboundCancelStressTest, FluxSwitchOnFirstStressTest.InboundSubscribeAndOutboundCancelAndInboundCompleteStressTest, FluxSwitchOnFirstStressTest.InboundSubscribeAndOutboundCancelAndInboundErrorStressTest, FluxSwitchOnFirstStressTest.LLLLLLLLL_Result, FluxSwitchOnFirstStressTest.OutboundCancelAndInboundCancelStressTest, FluxSwitchOnFirstStressTest.OutboundCancelAndInboundCompleteStressTest, FluxSwitchOnFirstStressTest.OutboundCancelAndInboundErrorStressTest, FluxSwitchOnFirstStressTest.OutboundCancelAndInboundNextStressTest, FluxSwitchOnFirstStressTest.OutboundOnSubscribeAndRequestStressTest

构造器概要

构造器

构造器和说明
OutboundCancelAndInboundCancelStressTest()

方法概要

限定符和类型	方法和说明
void	arbiter(FluxSwitchOnFirstStressTest.LLLLLLLLL_Result result)
void	cancelInbound()
void	cancelOutbound()
void	requestInbound()

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

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

构造器详细资料

OutboundCancelAndInboundCancelStressTest

public OutboundCancelAndInboundCancelStressTest()

方法详细资料

cancelInbound

public void cancelInbound()

requestInbound

public void requestInbound()

cancelOutbound

public void cancelOutbound()

arbiter

public void arbiter(FluxSwitchOnFirstStressTest.LLLLLLLLL_Result result)