reactor.core.publisher

类 OperatorsTest

java.lang.Object

reactor.core.publisher.OperatorsTest

public class OperatorsTest
extends java.lang.Object

构造器概要

构造器

构造器和说明
OperatorsTest()

方法概要

限定符和类型	方法和说明
void	addAndGetAtomicField()
void	addCap()
void	cancelledSubscription()
void	castAsQueueSubscription()
void	constructor()
void	convertConditionalToConditionalShouldReturnTheSameInstance()
void	convertNonConditionalToConditionalSubscriberTest()
void	discardAdapterIsAdditive()
void	discardAdapterRejectsNull()
void	discardCollectionContinuesWhenIteratorElementFailsToBeDiscarded()
void	discardCollectionStopsOnIsEmptyError()
void	discardCollectionStopsOnIterationError()
void	discardIteratorContinuesWhenIteratorElementFailsToBeDiscarded()
void	discardIteratorStopsOnIterationError()
void	discardQueueWithClearContinuesOnExtractedElementNotDiscarded()
void	discardQueueWithClearContinuesOnExtractionError()
void	discardQueueWithClearContinuesOnRawQueueElementNotDiscarded()
void	discardQueueWithClearStopsOnQueuePollingError()
void	discardStreamContinuesWhenElementFailsToBeDiscarded()
void	discardStreamStopsOnIterationError()
void	drainSubscriber()
void	liftVsLiftPublisher()
void	liftVsLiftRawWithPredicate()
void	noopFluxCancelled()
void	onErrorDroppedLocal()
void	onNextDroppedLocal()
void	onNextErrorModeLocalStrategy()
void	onNextFailureWithStrategyMatchingButNotNullDoesCancel()
void	onNextFailureWithStrategyMatchingDoesntCancel()
void	onNextFailureWithStrategyNotMatchingDoesCancel()
void	onOperatorErrorLocal()
void	onRejectedExecutionLocalTakesPrecedenceOverOnOperatorError()
void	onRejectedExecutionWithDataSignalDelegatesToErrorLocal()
void	onRejectedExecutionWithoutDataSignalDelegatesToErrorLocal()
void	pollErrorModeLocalStrategy()
void	reportThrowInSubscribeWithFuseableErrorResumed()
void	scanCancelledSubscription()
void	scanDeferredSubscription()
void	scanEmptySubscription()
void	scanMonoSubscriber()
void	scanMultiSubscriptionSubscriber()
void	scanScalarSubscription()
void	shouldBeSerialIfRacy()
void	testOnRejectedWithOutsideRee()
void	testOnRejectedWithReactorRee()
void	unboundedOrLimit()
void	unboundedOrLimitLowTide()
void	unboundedOrPrefetch()

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

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

构造器详细资料

OperatorsTest

public OperatorsTest()

方法详细资料

addAndGetAtomicField

@Test
public void addAndGetAtomicField()

addCap

@Test
public void addCap()

constructor

@Test
public void constructor()

castAsQueueSubscription

@Test
public void castAsQueueSubscription()

cancelledSubscription

@Test
public void cancelledSubscription()

noopFluxCancelled

@Test
public void noopFluxCancelled()

drainSubscriber

@Test
public void drainSubscriber()

scanCancelledSubscription

@Test
public void scanCancelledSubscription()

shouldBeSerialIfRacy

@Test
public void shouldBeSerialIfRacy()

scanDeferredSubscription

@Test
public void scanDeferredSubscription()

scanEmptySubscription

@Test
public void scanEmptySubscription()

scanMonoSubscriber

@Test
public void scanMonoSubscriber()

scanMultiSubscriptionSubscriber

@Test
public void scanMultiSubscriptionSubscriber()

scanScalarSubscription

@Test
public void scanScalarSubscription()

onNextErrorModeLocalStrategy

@Test
public void onNextErrorModeLocalStrategy()

pollErrorModeLocalStrategy

@Test
public void pollErrorModeLocalStrategy()

onErrorDroppedLocal

@Test
public void onErrorDroppedLocal()

onNextDroppedLocal

@Test
public void onNextDroppedLocal()

onOperatorErrorLocal

@Test
public void onOperatorErrorLocal()

onRejectedExecutionWithoutDataSignalDelegatesToErrorLocal

@Test
public void onRejectedExecutionWithoutDataSignalDelegatesToErrorLocal()

onRejectedExecutionWithDataSignalDelegatesToErrorLocal

@Test
public void onRejectedExecutionWithDataSignalDelegatesToErrorLocal()

onRejectedExecutionLocalTakesPrecedenceOverOnOperatorError

@Test
public void onRejectedExecutionLocalTakesPrecedenceOverOnOperatorError()

testOnRejectedWithReactorRee

@Test
public void testOnRejectedWithReactorRee()

testOnRejectedWithOutsideRee

@Test
public void testOnRejectedWithOutsideRee()

unboundedOrPrefetch

@Test
public void unboundedOrPrefetch()

unboundedOrLimit

@Test
public void unboundedOrLimit()

unboundedOrLimitLowTide

@Test
public void unboundedOrLimitLowTide()

onNextFailureWithStrategyMatchingDoesntCancel

@Test
public void onNextFailureWithStrategyMatchingDoesntCancel()

onNextFailureWithStrategyNotMatchingDoesCancel

@Test
public void onNextFailureWithStrategyNotMatchingDoesCancel()

onNextFailureWithStrategyMatchingButNotNullDoesCancel

@Test
public void onNextFailureWithStrategyMatchingButNotNullDoesCancel()

liftVsLiftPublisher

@Test
public void liftVsLiftPublisher()

liftVsLiftRawWithPredicate

@Test
public void liftVsLiftRawWithPredicate()

discardAdapterRejectsNull

@Test
public void discardAdapterRejectsNull()

discardAdapterIsAdditive

@Test
public void discardAdapterIsAdditive()

convertNonConditionalToConditionalSubscriberTest

@Test
public void convertNonConditionalToConditionalSubscriberTest()

convertConditionalToConditionalShouldReturnTheSameInstance

@Test
public void convertConditionalToConditionalShouldReturnTheSameInstance()

discardQueueWithClearContinuesOnExtractionError

@Test
public void discardQueueWithClearContinuesOnExtractionError()

discardQueueWithClearContinuesOnExtractedElementNotDiscarded

@Test
public void discardQueueWithClearContinuesOnExtractedElementNotDiscarded()

discardQueueWithClearContinuesOnRawQueueElementNotDiscarded

@Test
public void discardQueueWithClearContinuesOnRawQueueElementNotDiscarded()

discardQueueWithClearStopsOnQueuePollingError

@Test
public void discardQueueWithClearStopsOnQueuePollingError()

discardStreamContinuesWhenElementFailsToBeDiscarded

@Test
public void discardStreamContinuesWhenElementFailsToBeDiscarded()

discardStreamStopsOnIterationError

@Test
public void discardStreamStopsOnIterationError()

discardCollectionContinuesWhenIteratorElementFailsToBeDiscarded

@Test
public void discardCollectionContinuesWhenIteratorElementFailsToBeDiscarded()

discardCollectionStopsOnIterationError

@Test
public void discardCollectionStopsOnIterationError()

discardCollectionStopsOnIsEmptyError

@Test
public void discardCollectionStopsOnIsEmptyError()

discardIteratorContinuesWhenIteratorElementFailsToBeDiscarded

@Test
public void discardIteratorContinuesWhenIteratorElementFailsToBeDiscarded()

discardIteratorStopsOnIterationError

@Test
public void discardIteratorStopsOnIterationError()

reportThrowInSubscribeWithFuseableErrorResumed

@Test
public void reportThrowInSubscribeWithFuseableErrorResumed()