reactor.core

类 SwapDisposableTest

java.lang.Object

reactor.core.SwapDisposableTest

public class SwapDisposableTest
extends java.lang.Object

作者:

David Karnok

构造器概要

构造器

构造器和说明
SwapDisposableTest()

方法概要

限定符和类型	方法和说明
void	concurrentSetDisposableShouldNotInterleave()
void	getDisposableShouldReturnset()
void	notDisposedWhenReplaced()
void	replacingFirstUnderlyingCausesUnsubscription()
void	settingSameDisposableTwiceDoesUnsubscribeIt()
void	settingUnderlyingWhenUnsubscribedCausesImmediateUnsubscription()
void	settingUnderlyingWhenUnsubscribedCausesImmediateUnsubscriptionConcurrently()
void	setUp()
void	unsubscribingTwiceDoesUnsubscribeOnce()
void	unsubscribingWithoutUnderlyingDoesNothing()
void	unsubscribingWithSingleUnderlyingUnsubscribes()
void	whenUnsubscribingSecondUnderlyingUnsubscribed()

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

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

构造器详细资料

SwapDisposableTest

public SwapDisposableTest()

方法详细资料

setUp

@BeforeEach
public void setUp()

unsubscribingWithoutUnderlyingDoesNothing

@Test
public void unsubscribingWithoutUnderlyingDoesNothing()

getDisposableShouldReturnset

@Test
public void getDisposableShouldReturnset()

notDisposedWhenReplaced

@Test
public void notDisposedWhenReplaced()

unsubscribingTwiceDoesUnsubscribeOnce

@Test
public void unsubscribingTwiceDoesUnsubscribeOnce()

settingSameDisposableTwiceDoesUnsubscribeIt

@Test
public void settingSameDisposableTwiceDoesUnsubscribeIt()

unsubscribingWithSingleUnderlyingUnsubscribes

@Test
public void unsubscribingWithSingleUnderlyingUnsubscribes()

replacingFirstUnderlyingCausesUnsubscription

@Test
public void replacingFirstUnderlyingCausesUnsubscription()

whenUnsubscribingSecondUnderlyingUnsubscribed

@Test
public void whenUnsubscribingSecondUnderlyingUnsubscribed()

settingUnderlyingWhenUnsubscribedCausesImmediateUnsubscription

@Test
public void settingUnderlyingWhenUnsubscribedCausesImmediateUnsubscription()

settingUnderlyingWhenUnsubscribedCausesImmediateUnsubscriptionConcurrently

@Test
 @Timeout(value=1L)
public void settingUnderlyingWhenUnsubscribedCausesImmediateUnsubscriptionConcurrently()
                                                                                                            throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

concurrentSetDisposableShouldNotInterleave

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

抛出:

java.lang.InterruptedException