reactor.core.publisher.scenarios

类 FluxSpecTests

java.lang.Object

reactor.core.publisher.scenarios.FluxSpecTests

public class FluxSpecTests
extends java.lang.Object

构造器概要

构造器

构造器和说明
FluxSpecTests()

方法概要

限定符和类型	方法和说明
void	acceptedErrorsArePassedToRegisteredConsumer()
void	acceptedValuesArePassedToRegisteredConsumer()
void	aDifferentWayOfConsuming()
void	collectFromMultipleThread1()
void	combineLatestStreamData()
void	countRange()
void	deferredFluxInitialValueLaterAvailableUpToLongMax()
void	delayItems()
void	fluxCanBeEnforcedToDispatchDistinctValues()
void	fluxCanBeEnforcedToDispatchValuesDistinctFromPredecessors()
void	fluxCanBeEnforcedToDispatchValuesHavingDistinctKeys()
void	fluxCanBeEnforcedToDispatchValuesWithKeysDistinctFromPredecessors()
void	fluxCanBeTranslatedToCompletableQueue()
void	fluxCanBeTranslatedToList()
void	fluxCanCheckForValueSatisfyingPredicate()
void	fluxCanFilterTerminalStates()
void	fluxCanListenForTerminalStates()
void	fluxCanReturnValueAtCertainIndex()
void	fluxCanReturnValueAtCertainIndexOrDefaultValue()
void	fluxCanSampleValuesOverTime()
void	fluxCanSampleValuesOverTimeTake()
void	fluxInitialValueAvailableOnceIfBroadcasted()
void	fluxInitialValueCanBeConsumedMultipleTimes()
void	fluxInitialValuesArePassedToConsumers()
void	fluxItemCanBeShiftedByTime()
void	fluxItemCanBeShiftedByTime2()
void	fluxValuesCanBeFiltered()
void	fluxValuesCanBeMapped()
void	knownNumberOfValuesCanBeReduced()
void	knownSetOfValuesCanBeReduced()
void	mappedConcat()
void	multipleStreamValuesCanBeMerged()
void	readQueuesFromPublishers()
void	reduceWillAccumulateListOfAcceptedValues()
void	simpleConcat()
void	streamCanBeCounted()
void	streamCanEmitDefaultValueIfEmpty()
void	streamStateRelatedSignalsCanBeConsumed()
void	streamValuesCanBeExploded()
void	whenAcceptedEventIsIterableSplitCanIterateOverValues()
void	whenFilterFunctionThrowsFilteredComposableAcceptsError()
void	whenKnownNumberOfValuesIsReducedOnlyFinalValueMadeAvailable()
void	whenMappingFunctionThrowsMappedComposableAcceptsError()
void	whenProcessorIsStreamed()
void	whenReducingKnownNumberOfValuesOnlyFinalValueIsPassedToConsumers()
void	whenReducingKnownSetOfValuesOnlyFinalValueIsPassedToConsumers()
void	whenUnknownNumberOfValueScannedEachReductionPassedToConsumer()
void	whenUnknownNumberOfValuesReducedEachReductionPassedToConsumerOnWindow()

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

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

构造器详细资料

FluxSpecTests

public FluxSpecTests()

方法详细资料

fluxInitialValueAvailableOnceIfBroadcasted

@Test
public void fluxInitialValueAvailableOnceIfBroadcasted()

deferredFluxInitialValueLaterAvailableUpToLongMax

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

抛出:

java.lang.InterruptedException

fluxInitialValueCanBeConsumedMultipleTimes

@Test
public void fluxInitialValueCanBeConsumedMultipleTimes()

fluxCanFilterTerminalStates

@Test
public void fluxCanFilterTerminalStates()

fluxCanListenForTerminalStates

@Test
public void fluxCanListenForTerminalStates()

fluxCanBeTranslatedToList

@Test
public void fluxCanBeTranslatedToList()

fluxCanBeTranslatedToCompletableQueue

@Test
public void fluxCanBeTranslatedToCompletableQueue()

readQueuesFromPublishers

@Test
public void readQueuesFromPublishers()

fluxCanSampleValuesOverTime

@Test
public void fluxCanSampleValuesOverTime()

fluxCanSampleValuesOverTimeTake

@Test
public void fluxCanSampleValuesOverTimeTake()

fluxCanBeEnforcedToDispatchValuesDistinctFromPredecessors

@Test
public void fluxCanBeEnforcedToDispatchValuesDistinctFromPredecessors()

fluxCanBeEnforcedToDispatchValuesWithKeysDistinctFromPredecessors

@Test
public void fluxCanBeEnforcedToDispatchValuesWithKeysDistinctFromPredecessors()

fluxCanBeEnforcedToDispatchDistinctValues

@Test
public void fluxCanBeEnforcedToDispatchDistinctValues()

fluxCanBeEnforcedToDispatchValuesHavingDistinctKeys

@Test
public void fluxCanBeEnforcedToDispatchValuesHavingDistinctKeys()

fluxCanCheckForValueSatisfyingPredicate

@Test
public void fluxCanCheckForValueSatisfyingPredicate()

fluxInitialValuesArePassedToConsumers

@Test
public void fluxInitialValuesArePassedToConsumers()

streamStateRelatedSignalsCanBeConsumed

@Test
public void streamStateRelatedSignalsCanBeConsumed()

streamCanEmitDefaultValueIfEmpty

@Test
public void streamCanEmitDefaultValueIfEmpty()

acceptedValuesArePassedToRegisteredConsumer

@Test
public void acceptedValuesArePassedToRegisteredConsumer()

acceptedErrorsArePassedToRegisteredConsumer

@Test
public void acceptedErrorsArePassedToRegisteredConsumer()

whenAcceptedEventIsIterableSplitCanIterateOverValues

@Test
public void whenAcceptedEventIsIterableSplitCanIterateOverValues()

fluxValuesCanBeMapped

@Test
public void fluxValuesCanBeMapped()

streamValuesCanBeExploded

@Test
public void streamValuesCanBeExploded()

multipleStreamValuesCanBeMerged

@Test
public void multipleStreamValuesCanBeMerged()

aDifferentWayOfConsuming

@Test
public void aDifferentWayOfConsuming()

combineLatestStreamData

@Test
public void combineLatestStreamData()

simpleConcat

@Test
public void simpleConcat()

mappedConcat

@Test
public void mappedConcat()

streamCanBeCounted

@Test
public void streamCanBeCounted()

fluxCanReturnValueAtCertainIndex

@Test
public void fluxCanReturnValueAtCertainIndex()

fluxCanReturnValueAtCertainIndexOrDefaultValue

@Test
public void fluxCanReturnValueAtCertainIndexOrDefaultValue()

fluxValuesCanBeFiltered

@Test
public void fluxValuesCanBeFiltered()

whenMappingFunctionThrowsMappedComposableAcceptsError

@Test
public void whenMappingFunctionThrowsMappedComposableAcceptsError()

whenProcessorIsStreamed

@Test
public void whenProcessorIsStreamed()

whenFilterFunctionThrowsFilteredComposableAcceptsError

@Test
public void whenFilterFunctionThrowsFilteredComposableAcceptsError()

knownSetOfValuesCanBeReduced

@Test
public void knownSetOfValuesCanBeReduced()

whenReducingKnownSetOfValuesOnlyFinalValueIsPassedToConsumers

@Test
public void whenReducingKnownSetOfValuesOnlyFinalValueIsPassedToConsumers()

whenReducingKnownNumberOfValuesOnlyFinalValueIsPassedToConsumers

@Test
public void whenReducingKnownNumberOfValuesOnlyFinalValueIsPassedToConsumers()

knownNumberOfValuesCanBeReduced

@Test
public void knownNumberOfValuesCanBeReduced()

whenKnownNumberOfValuesIsReducedOnlyFinalValueMadeAvailable

@Test
public void whenKnownNumberOfValuesIsReducedOnlyFinalValueMadeAvailable()

whenUnknownNumberOfValueScannedEachReductionPassedToConsumer

@Test
public void whenUnknownNumberOfValueScannedEachReductionPassedToConsumer()

reduceWillAccumulateListOfAcceptedValues

@Test
public void reduceWillAccumulateListOfAcceptedValues()

whenUnknownNumberOfValuesReducedEachReductionPassedToConsumerOnWindow

@Test
public void whenUnknownNumberOfValuesReducedEachReductionPassedToConsumerOnWindow()

countRange

@Test
public void countRange()

delayItems

@Test
public void delayItems()

fluxItemCanBeShiftedByTime

@Test
public void fluxItemCanBeShiftedByTime()

fluxItemCanBeShiftedByTime2

@Test
public void fluxItemCanBeShiftedByTime2()

collectFromMultipleThread1

@Test
 @Timeout(value=10L)
public void collectFromMultipleThread1()
                                                             throws java.lang.Exception

抛出:

java.lang.Exception