reactor.core.publisher

类 MonoMetricsFuseableTest

java.lang.Object

reactor.core.publisher.MonoMetricsFuseableTest

public class MonoMetricsFuseableTest
extends java.lang.Object

构造器概要

构造器

构造器和说明
MonoMetricsFuseableTest()

方法概要

限定符和类型	方法和说明
void	completeEmptyNoFusion()
void	completeEmptySyncFusion()
void	completeWithElementNoFusion()
void	completeWithElementSyncFusion()
void	countsSubscriptionsFuseable()
void	noOnNextTimerFuseable()
void	noRequestTrackingEvenForNamedSequence()
void	queueClearEmptySizeDelegates()
void	queueClearEmptySizeWhenQueueSubscriptionNull()
void	queuePollDoesntTrackOnNext()
void	queuePollError()
void	queuePollSyncTracksOnComplete()
void	removeRegistry()
void	requestFusionDelegates()
void	scanOperator()
void	scanSubscriber()
void	setupRegistry()
void	splitMetricsOnNameFuseable()
void	subscribeToCancelFuseable()
void	subscribeToErrorFuseable()
void	testUsesMicrometerFuseable()
void	usesTagsFuseable()

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

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

构造器详细资料

MonoMetricsFuseableTest

public MonoMetricsFuseableTest()

方法详细资料

setupRegistry

@BeforeEach
public void setupRegistry()

removeRegistry

@AfterEach
public void removeRegistry()

scanOperator

@Test
public void scanOperator()

scanSubscriber

@Test
public void scanSubscriber()

queueClearEmptySizeDelegates

@Test
public void queueClearEmptySizeDelegates()

queueClearEmptySizeWhenQueueSubscriptionNull

@Test
public void queueClearEmptySizeWhenQueueSubscriptionNull()

queuePollDoesntTrackOnNext

@Test
public void queuePollDoesntTrackOnNext()

queuePollSyncTracksOnComplete

@Test
public void queuePollSyncTracksOnComplete()

queuePollError

@Test
public void queuePollError()

requestFusionDelegates

@Test
public void requestFusionDelegates()

testUsesMicrometerFuseable

@Test
public void testUsesMicrometerFuseable()

splitMetricsOnNameFuseable

@Test
public void splitMetricsOnNameFuseable()

usesTagsFuseable

@Test
public void usesTagsFuseable()

noOnNextTimerFuseable

@Test
public void noOnNextTimerFuseable()

completeEmptyNoFusion

@Test
public void completeEmptyNoFusion()

completeEmptySyncFusion

@Test
public void completeEmptySyncFusion()

completeWithElementNoFusion

@Test
public void completeWithElementNoFusion()

completeWithElementSyncFusion

@Test
public void completeWithElementSyncFusion()

subscribeToErrorFuseable

@Test
public void subscribeToErrorFuseable()

subscribeToCancelFuseable

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

抛出:

java.lang.InterruptedException

countsSubscriptionsFuseable

@Test
public void countsSubscriptionsFuseable()

noRequestTrackingEvenForNamedSequence

@Test
public void noRequestTrackingEvenForNamedSequence()