reactor.core.publisher

类 FluxRefCountGraceTest

java.lang.Object

reactor.core.publisher.FluxRefCountGraceTest

public class FluxRefCountGraceTest
extends java.lang.Object

构造器概要

构造器

构造器和说明
FluxRefCountGraceTest()

方法概要

限定符和类型	方法和说明
void	avoidUnexpectedDoubleCancel()
void	doesDisconnectAfterRefCountZeroAndSlowResubscribe()
void	doesntDisconnectAfterRefCountZeroAndQuickResubscribe()
void	error()
void	raceSubscribeAndCancel()
void	raceSubscribeAndCancelNoTimeout()
void	scanInner()
void	scanOperator()
void	shouldNotRetainSubscriptionToSourceWhenComplete()
void	sizeOneCanRepeat()
void	sizeOneCanRetry()
void	subscribersComeAndGoBelowThreshold()
void	testFusion()
void	upstreamCompletes()
void	upstreamCompletesTwoSubscribers()

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

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

构造器详细资料

FluxRefCountGraceTest

public FluxRefCountGraceTest()

方法详细资料

avoidUnexpectedDoubleCancel

@Test
public void avoidUnexpectedDoubleCancel()

sizeOneCanRetry

@Test
public void sizeOneCanRetry()

sizeOneCanRepeat

@Test
public void sizeOneCanRepeat()

raceSubscribeAndCancel

@Test
public void raceSubscribeAndCancel()

raceSubscribeAndCancelNoTimeout

@Test
 @Tag(value="slow")
public void raceSubscribeAndCancelNoTimeout()

error

@Test
public void error()

upstreamCompletes

@Test
public void upstreamCompletes()

upstreamCompletesTwoSubscribers

@Test
public void upstreamCompletesTwoSubscribers()

subscribersComeAndGoBelowThreshold

@Test
public void subscribersComeAndGoBelowThreshold()

testFusion

@Test
public void testFusion()

doesntDisconnectAfterRefCountZeroAndQuickResubscribe

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

抛出:

java.lang.InterruptedException

doesDisconnectAfterRefCountZeroAndSlowResubscribe

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

抛出:

java.lang.InterruptedException

shouldNotRetainSubscriptionToSourceWhenComplete

@Test
public void shouldNotRetainSubscriptionToSourceWhenComplete()
                                                            throws java.lang.Exception

抛出:

java.lang.Exception

scanOperator

@Test
public void scanOperator()

scanInner

@Test
public void scanInner()