reactor.core.publisher

类 OnDiscardShouldNotLeakTest

java.lang.Object

reactor.core.publisher.OnDiscardShouldNotLeakTest

@Tag(value="slow")
public class OnDiscardShouldNotLeakTest
extends java.lang.Object

构造器概要

构造器

构造器和说明
OnDiscardShouldNotLeakTest()

方法概要

限定符和类型	方法和说明
static java.util.List<org.junit.jupiter.params.provider.Arguments>	data()
void	ensureMultipleSubscribersSupportWithNoLeaksWhenPopulatedQueueRacingCancelAndOnNextAndRequest(boolean conditional, boolean fused, reactor.core.publisher.OnDiscardShouldNotLeakTest.DiscardScenario discardScenario)
void	ensureMultipleSubscribersSupportWithNoLeaksWhenRacingCancelAndOnNextAndRequest(boolean conditional, boolean fused, reactor.core.publisher.OnDiscardShouldNotLeakTest.DiscardScenario discardScenario)
void	ensureNoLeaksPopulatedQueueAndRacingCancelAndOnComplete(boolean conditional, boolean fused, reactor.core.publisher.OnDiscardShouldNotLeakTest.DiscardScenario discardScenario)
void	ensureNoLeaksPopulatedQueueAndRacingCancelAndOnError(boolean conditional, boolean fused, reactor.core.publisher.OnDiscardShouldNotLeakTest.DiscardScenario discardScenario)
void	ensureNoLeaksPopulatedQueueAndRacingCancelAndOnNext(boolean conditional, boolean fused, reactor.core.publisher.OnDiscardShouldNotLeakTest.DiscardScenario discardScenario)
void	ensureNoLeaksPopulatedQueueAndRacingCancelAndOverflowError(boolean conditional, boolean fused, reactor.core.publisher.OnDiscardShouldNotLeakTest.DiscardScenario discardScenario)
void	ensureNoLeaksPopulatedQueueAndRacingCancelAndRequest(boolean conditional, boolean fused, reactor.core.publisher.OnDiscardShouldNotLeakTest.DiscardScenario discardScenario)

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

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

构造器详细资料

OnDiscardShouldNotLeakTest

public OnDiscardShouldNotLeakTest()

方法详细资料

data

public static java.util.List<org.junit.jupiter.params.provider.Arguments> data()

ensureMultipleSubscribersSupportWithNoLeaksWhenRacingCancelAndOnNextAndRequest

@DisplayName(value="Multiple Subscribers racing Cancel/OnNext/Request")
 @ParameterizedTest(name="{displayName} [{index}] {2}")
 @MethodSource(value="data")
public void ensureMultipleSubscribersSupportWithNoLeaksWhenRacingCancelAndOnNextAndRequest(boolean conditional,
                                                                                                                                                                                                                                                           boolean fused,
                                                                                                                                                                                                                                                           reactor.core.publisher.OnDiscardShouldNotLeakTest.DiscardScenario discardScenario)

ensureMultipleSubscribersSupportWithNoLeaksWhenPopulatedQueueRacingCancelAndOnNextAndRequest

@DisplayName(value="Multiple Subscribers with populated queue racing Cancel/OnNext/Request")
 @ParameterizedTest(name="{displayName} [{index}] {2}")
 @MethodSource(value="data")
public void ensureMultipleSubscribersSupportWithNoLeaksWhenPopulatedQueueRacingCancelAndOnNextAndRequest(boolean conditional,
                                                                                                                                                                                                                                                                                              boolean fused,
                                                                                                                                                                                                                                                                                              reactor.core.publisher.OnDiscardShouldNotLeakTest.DiscardScenario discardScenario)

ensureNoLeaksPopulatedQueueAndRacingCancelAndOnNext

@DisplayName(value="Populated queue racing Cancel/OnNext")
 @ParameterizedTest(name="{displayName} [{index}] {2}")
 @MethodSource(value="data")
public void ensureNoLeaksPopulatedQueueAndRacingCancelAndOnNext(boolean conditional,
                                                                                                                                                                                                                   boolean fused,
                                                                                                                                                                                                                   reactor.core.publisher.OnDiscardShouldNotLeakTest.DiscardScenario discardScenario)

ensureNoLeaksPopulatedQueueAndRacingCancelAndOnComplete

@DisplayName(value="Populated queue racing Cancel/OnComplete")
 @ParameterizedTest(name="{displayName} [{index}] {2}")
 @MethodSource(value="data")
public void ensureNoLeaksPopulatedQueueAndRacingCancelAndOnComplete(boolean conditional,
                                                                                                                                                                                                                           boolean fused,
                                                                                                                                                                                                                           reactor.core.publisher.OnDiscardShouldNotLeakTest.DiscardScenario discardScenario)

ensureNoLeaksPopulatedQueueAndRacingCancelAndOnError

@DisplayName(value="Populated queue racing Cancel/OnError")
 @ParameterizedTest(name="{displayName} [{index}] {2}")
 @MethodSource(value="data")
public void ensureNoLeaksPopulatedQueueAndRacingCancelAndOnError(boolean conditional,
                                                                                                                                                                                                                     boolean fused,
                                                                                                                                                                                                                     reactor.core.publisher.OnDiscardShouldNotLeakTest.DiscardScenario discardScenario)

ensureNoLeaksPopulatedQueueAndRacingCancelAndOverflowError

@DisplayName(value="Populated queue racing Cancel/overflow Error")
 @ParameterizedTest(name="{displayName} [{index}] {2}")
 @MethodSource(value="data")
public void ensureNoLeaksPopulatedQueueAndRacingCancelAndOverflowError(boolean conditional,
                                                                                                                                                                                                                                  boolean fused,
                                                                                                                                                                                                                                  reactor.core.publisher.OnDiscardShouldNotLeakTest.DiscardScenario discardScenario)

ensureNoLeaksPopulatedQueueAndRacingCancelAndRequest

@DisplayName(value="Populated queue racing Cancel/Request")
 @ParameterizedTest(name="{displayName} [{index}] {2}")
 @MethodSource(value="data")
public void ensureNoLeaksPopulatedQueueAndRacingCancelAndRequest(boolean conditional,
                                                                                                                                                                                                                     boolean fused,
                                                                                                                                                                                                                     reactor.core.publisher.OnDiscardShouldNotLeakTest.DiscardScenario discardScenario)