public class LambdaSubscriberTest
extends java.lang.Object
构造器和说明 |
---|
LambdaSubscriberTest() |
限定符和类型 | 方法和说明 |
---|---|
void |
consumeOnSubscriptionNotifiesError() |
void |
consumeOnSubscriptionReceivesSubscriptionAndRequests32() |
void |
consumeOnSubscriptionThrowsFatal() |
void |
initialContextIsUsedForOnErrorDropped() |
void |
initialContextIsVisibleToUpstream() |
void |
noSubscriptionConsumerTriggersRequestOfMax() |
void |
onNextConsumerExceptionTriggersCancellation() |
void |
onNextConsumerFatalDoesntTriggerCancellation() |
void |
scan() |
@Test public void initialContextIsVisibleToUpstream()
@Test public void initialContextIsUsedForOnErrorDropped()
@Test public void consumeOnSubscriptionNotifiesError()
@Test public void consumeOnSubscriptionThrowsFatal()
@Test public void consumeOnSubscriptionReceivesSubscriptionAndRequests32()
@Test public void noSubscriptionConsumerTriggersRequestOfMax()
@Test public void onNextConsumerExceptionTriggersCancellation()
@Test public void onNextConsumerFatalDoesntTriggerCancellation()
@Test public void scan()