reactor.core.publisher

类 SinkManyReplayProcessorTest

java.lang.Object

reactor.core.publisher.SinkManyReplayProcessorTest

public class SinkManyReplayProcessorTest
extends java.lang.Object

构造器概要

构造器

构造器和说明
SinkManyReplayProcessorTest()

方法概要

限定符和类型	方法和说明
void	bounded()
void	boundedAfter()
void	boundedFused()
void	boundedFusedAfter()
void	boundedFusedError()
void	boundedLong()
void	boundedLongError()
void	boundedOnSubscribeAndState()
void	cancel()
void	currentSubscriberCount()
void	failNegativeBufferBoundedAndTimed()
void	failNegativeBufferSizeBounded()
void	inners()
void	scanProcessor()
void	scanProcessorUnboundedCapacity()
void	teardownVirtualTime()
void	timed()
void	timedAfter()
void	timedAndBound()
void	timedAndBoundAfter()
void	timedAndBoundedOnSubscribeAndState()
void	timedAndBoundError()
void	timedAndBoundFused()
void	timedAndBoundFusedError()
void	timedError()
void	timedFused()
void	timedFusedAfter()
void	timedFusedError()
void	timedOnSubscribeAndState()
void	unbounded()
void	unboundedAfter()
void	unboundedFused()
void	unboundedFusedError()
void	unboundedLong()
void	unboundedOnSubscribeAndState()
void	virtualTime()

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

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

构造器详细资料

SinkManyReplayProcessorTest

public SinkManyReplayProcessorTest()

方法详细资料

virtualTime

@BeforeEach
public void virtualTime()

teardownVirtualTime

@AfterEach
public void teardownVirtualTime()

currentSubscriberCount

@Test
public void currentSubscriberCount()

unbounded

@Test
public void unbounded()

bounded

@Test
public void bounded()

cancel

@Test
public void cancel()

unboundedAfter

@Test
public void unboundedAfter()

boundedAfter

@Test
public void boundedAfter()

unboundedLong

@Test
public void unboundedLong()

boundedLong

@Test
public void boundedLong()

boundedLongError

@Test
public void boundedLongError()

unboundedFused

@Test
public void unboundedFused()

unboundedFusedError

@Test
public void unboundedFusedError()

boundedFused

@Test
public void boundedFused()

boundedFusedError

@Test
public void boundedFusedError()

boundedFusedAfter

@Test
public void boundedFusedAfter()

timed

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

抛出:

java.lang.Exception

timedError

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

抛出:

java.lang.Exception

timedAfter

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

抛出:

java.lang.Exception

timedFused

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

抛出:

java.lang.Exception

timedFusedError

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

抛出:

java.lang.Exception

timedFusedAfter

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

抛出:

java.lang.Exception

timedAndBound

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

抛出:

java.lang.Exception

timedAndBoundError

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

抛出:

java.lang.Exception

timedAndBoundAfter

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

抛出:

java.lang.Exception

timedAndBoundFused

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

抛出:

java.lang.Exception

timedAndBoundFusedError

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

抛出:

java.lang.Exception

timedAndBoundedOnSubscribeAndState

@Test
public void timedAndBoundedOnSubscribeAndState()

timedOnSubscribeAndState

@Test
public void timedOnSubscribeAndState()

unboundedOnSubscribeAndState

@Test
public void unboundedOnSubscribeAndState()

boundedOnSubscribeAndState

@Test
public void boundedOnSubscribeAndState()

failNegativeBufferSizeBounded

@Test
public void failNegativeBufferSizeBounded()

failNegativeBufferBoundedAndTimed

@Test
public void failNegativeBufferBoundedAndTimed()

scanProcessor

@Test
public void scanProcessor()

scanProcessorUnboundedCapacity

@Test
public void scanProcessorUnboundedCapacity()

inners

@Test
public void inners()