reactor.core.publisher

类 FluxRefCountTest

java.lang.Object

reactor.core.publisher.FluxRefCountTest

public class FluxRefCountTest
extends java.lang.Object

构造器概要

构造器

构造器和说明
FluxRefCountTest()

方法概要

限定符和类型	方法和说明
void	asyncRetry()
void	avoidUnexpectedDoubleCancel()
void	cancelDoesntTriggerDisconnectErrorOnFirstSubscribeDoComplete()
void	cancelDoesntTriggerDisconnectErrorOnFirstSubscribeNoComplete()
void	delayElementShouldNotCancelTwice()
void	normal()
void	normalTwoSubscribers()
void	raceSubscribeAndCancel()
void	reconnectsAfterRefCountZero()
void	scanInner()
void	scanInnerCancelled()
void	scanMain()
void	sizeOneCanRepeat()
void	sizeOneCanRetry()
void	subscribersComeAndGoBelowThreshold()
void	upstreamCompletes()
void	upstreamCompletesTwoSubscribers()

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

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

构造器详细资料

FluxRefCountTest

public FluxRefCountTest()

方法详细资料

avoidUnexpectedDoubleCancel

@Test
public void avoidUnexpectedDoubleCancel()

sizeOneCanRetry

@Test
public void sizeOneCanRetry()

sizeOneCanRepeat

@Test
public void sizeOneCanRepeat()

raceSubscribeAndCancel

@Test
public void raceSubscribeAndCancel()

cancelDoesntTriggerDisconnectErrorOnFirstSubscribeNoComplete

@Test
public void cancelDoesntTriggerDisconnectErrorOnFirstSubscribeNoComplete()

cancelDoesntTriggerDisconnectErrorOnFirstSubscribeDoComplete

@Test
public void cancelDoesntTriggerDisconnectErrorOnFirstSubscribeDoComplete()

normal

@Test
public void normal()

normalTwoSubscribers

@Test
public void normalTwoSubscribers()

upstreamCompletes

@Test
public void upstreamCompletes()

upstreamCompletesTwoSubscribers

@Test
public void upstreamCompletesTwoSubscribers()

subscribersComeAndGoBelowThreshold

@Test
public void subscribersComeAndGoBelowThreshold()

asyncRetry

@Test
public void asyncRetry()

reconnectsAfterRefCountZero

@Test
public void reconnectsAfterRefCountZero()

delayElementShouldNotCancelTwice

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

抛出:

java.lang.Exception

scanMain

@Test
public void scanMain()

scanInner

@Test
public void scanInner()

scanInnerCancelled

@Test
public void scanInnerCancelled()