reactor.core.publisher

类 LambdaMonoSubscriberTest

java.lang.Object

reactor.core.publisher.LambdaMonoSubscriberTest

public class LambdaMonoSubscriberTest
extends java.lang.Object

构造器概要

构造器

构造器和说明
LambdaMonoSubscriberTest()

方法概要

限定符和类型	方法和说明
void	completeHookErrorDropped()
void	consumeOnSubscriptionNotifiesError()
void	consumeOnSubscriptionReceivesSubscriptionAndRequests32()
void	consumeOnSubscriptionThrowsFatal()
void	emptyMonoState()
void	errorMonoState()
void	initialContextIsUsedForOnErrorDropped()
void	initialContextIsVisibleToUpstream()
void	noSubscriptionConsumerTriggersRequestOfMax()
void	onNextConsumerExceptionTriggersCancellation()
void	scan()
void	testCancel()

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

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

构造器详细资料

LambdaMonoSubscriberTest

public LambdaMonoSubscriberTest()

方法详细资料

initialContextIsVisibleToUpstream

@Test
public void initialContextIsVisibleToUpstream()

initialContextIsUsedForOnErrorDropped

@Test
public void initialContextIsUsedForOnErrorDropped()

consumeOnSubscriptionNotifiesError

@Test
public void consumeOnSubscriptionNotifiesError()

consumeOnSubscriptionThrowsFatal

@Test
public void consumeOnSubscriptionThrowsFatal()

consumeOnSubscriptionReceivesSubscriptionAndRequests32

@Test
public void consumeOnSubscriptionReceivesSubscriptionAndRequests32()

noSubscriptionConsumerTriggersRequestOfMax

@Test
public void noSubscriptionConsumerTriggersRequestOfMax()

onNextConsumerExceptionTriggersCancellation

@Test
public void onNextConsumerExceptionTriggersCancellation()

emptyMonoState

@Test
public void emptyMonoState()

errorMonoState

@Test
public void errorMonoState()

completeHookErrorDropped

@Test
public void completeHookErrorDropped()

testCancel

@Test
public void testCancel()

scan

@Test
public void scan()