reactor.core.publisher

类 FluxWindowPredicateTest

java.lang.Object

reactor.test.publisher.BaseOperatorTest<I,Flux<I>,O,Flux<O>>

reactor.test.publisher.FluxOperatorTest<java.lang.String,Flux<java.lang.String>>

reactor.core.publisher.FluxWindowPredicateTest

public class FluxWindowPredicateTest
extends FluxOperatorTest<java.lang.String,Flux<java.lang.String>>

嵌套类概要

从类继承的嵌套类/接口 reactor.test.publisher.FluxOperatorTest

FluxOperatorTest.Scenario<I,O>

构造器概要

构造器

构造器和说明
FluxWindowPredicateTest()

方法概要

限定符和类型	方法和说明
void	apiUntil()
void	apiUntilCutAfter()
void	apiUntilCutBefore()
void	apiWhile()
void	discardOnCancelWindowUntil()
void	discardOnCancelWindowUntilCutBefore()
void	discardOnCancelWindowWhile()
void	innerCancellationCancelsMainSequence()
void	mainErrorUntilCutBeforeIsPropagatedToBothWindowAndMain()
void	mainErrorUntilIsPropagatedToBothWindowAndMain()
void	mainErrorWhileIsPropagatedOnlyToMain()
void	manualRequestWindowUntilOverRequestingSourceByPrefetch()
void	manualRequestWindowWhileOverRequestingSourceByPrefetch()
void	mismatchAtBeginningUntil()
void	mismatchAtBeginningUntilCutBefore()
void	mismatchAtBeginningWhile()
void	normalUntil()
void	normalUntilCutBefore()
void	normalWhile()
void	normalWhileDoesntInitiallyMatch()
void	normalWhileDoesntMatch()
void	onCompletionBeforeLastBoundaryWindowEmitted()
void	predicateErrorUntil()
void	predicateErrorUntilCutBefore()
void	predicateErrorWhile()
void	prefetchIntegerMaxIsRequestUnboundedUntil()
void	prefetchIntegerMaxIsRequestUnboundedWhile()
void	scanMainSubscriber()
void	scanOperator()
void	scanOtherSubscriber()
void	untilChangedDisposesStateOnCancel()
void	untilChangedDisposesStateOnComplete()
void	untilChangedDisposesStateOnError()
void	untilChangedNoRepetition()
void	untilChangedSomeRepetition()
void	whileOnlySeparatorsGivesSequenceOfWindows()
void	whileRequestOneByOne()
void	whileStartingSeveralSeparatorsEachCreateEmptyWindow()
void	windowUntilCutBeforeIntentionallyEmptyWindows()
void	windowUntilCutBeforeNoEmptyWindows()
void	windowUntilIntentionallyEmptyWindows()
void	windowUntilNoEmptyWindows()
void	windowUntilUnboundedStartingDelimiterReplenishes()
void	windowWhileIntentionallyEmptyWindows()
void	windowWhileNoEmptyWindows()
void	windowWhileNotPropagatingCancelToSource_disposeInnerFirst()
void	windowWhileNotPropagatingCancelToSource_withConcat()
void	windowWhileOneByOneStartingDelimiterReplenishes()
void	windowWhilePropagatingCancelToSource_disposeOuterFirst()
void	windowWhileUnboundedStartingDelimiterReplenishes()

从类继承的方法 reactor.test.publisher.FluxOperatorTest

scenario

从类继承的方法 reactor.test.publisher.BaseOperatorTest

assertPrePostState, cancelOnSubscribe, errorOnSubscribe, initDefaultScenario, sequenceOfNextAndCancel, sequenceOfNextAndComplete, sequenceOfNextAndError, sequenceOfNextWithCallbackError

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

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

构造器详细资料

FluxWindowPredicateTest

public FluxWindowPredicateTest()

方法详细资料

windowWhilePropagatingCancelToSource_disposeOuterFirst

@Test
public void windowWhilePropagatingCancelToSource_disposeOuterFirst()

windowWhileNotPropagatingCancelToSource_disposeInnerFirst

@Test
public void windowWhileNotPropagatingCancelToSource_disposeInnerFirst()

windowWhileNotPropagatingCancelToSource_withConcat

@Test
public void windowWhileNotPropagatingCancelToSource_withConcat()

windowWhileNoEmptyWindows

@Test
public void windowWhileNoEmptyWindows()

windowUntilNoEmptyWindows

@Test
public void windowUntilNoEmptyWindows()

windowUntilCutBeforeNoEmptyWindows

@Test
public void windowUntilCutBeforeNoEmptyWindows()

windowWhileIntentionallyEmptyWindows

@Test
public void windowWhileIntentionallyEmptyWindows()

windowUntilIntentionallyEmptyWindows

@Test
public void windowUntilIntentionallyEmptyWindows()

windowUntilCutBeforeIntentionallyEmptyWindows

@Test
public void windowUntilCutBeforeIntentionallyEmptyWindows()

untilChangedNoRepetition

@Test
public void untilChangedNoRepetition()

untilChangedSomeRepetition

@Test
public void untilChangedSomeRepetition()

untilChangedDisposesStateOnComplete

@Test
public void untilChangedDisposesStateOnComplete()

untilChangedDisposesStateOnError

@Test
public void untilChangedDisposesStateOnError()

untilChangedDisposesStateOnCancel

@Test
public void untilChangedDisposesStateOnCancel()

apiUntil

@Test
public void apiUntil()

apiUntilCutAfter

@Test
public void apiUntilCutAfter()

apiUntilCutBefore

@Test
public void apiUntilCutBefore()

apiWhile

@Test
public void apiWhile()

normalUntil

@Test
public void normalUntil()

onCompletionBeforeLastBoundaryWindowEmitted

@Test
public void onCompletionBeforeLastBoundaryWindowEmitted()

mainErrorUntilIsPropagatedToBothWindowAndMain

@Test
public void mainErrorUntilIsPropagatedToBothWindowAndMain()

predicateErrorUntil

@Test
public void predicateErrorUntil()

normalUntilCutBefore

@Test
public void normalUntilCutBefore()

mainErrorUntilCutBeforeIsPropagatedToBothWindowAndMain

@Test
public void mainErrorUntilCutBeforeIsPropagatedToBothWindowAndMain()

predicateErrorUntilCutBefore

@Test
public void predicateErrorUntilCutBefore()

normalWhile

@Test
public void normalWhile()

normalWhileDoesntInitiallyMatch

@Test
public void normalWhileDoesntInitiallyMatch()

normalWhileDoesntMatch

@Test
public void normalWhileDoesntMatch()

mainErrorWhileIsPropagatedOnlyToMain

@Test
public void mainErrorWhileIsPropagatedOnlyToMain()

whileStartingSeveralSeparatorsEachCreateEmptyWindow

@Test
public void whileStartingSeveralSeparatorsEachCreateEmptyWindow()

whileOnlySeparatorsGivesSequenceOfWindows

@Test
public void whileOnlySeparatorsGivesSequenceOfWindows()

predicateErrorWhile

@Test
public void predicateErrorWhile()

whileRequestOneByOne

@Test
public void whileRequestOneByOne()

mismatchAtBeginningUntil

@Test
public void mismatchAtBeginningUntil()

mismatchAtBeginningUntilCutBefore

@Test
public void mismatchAtBeginningUntilCutBefore()

mismatchAtBeginningWhile

@Test
public void mismatchAtBeginningWhile()

innerCancellationCancelsMainSequence

@Test
public void innerCancellationCancelsMainSequence()

prefetchIntegerMaxIsRequestUnboundedUntil

@Test
public void prefetchIntegerMaxIsRequestUnboundedUntil()

prefetchIntegerMaxIsRequestUnboundedWhile

@Test
public void prefetchIntegerMaxIsRequestUnboundedWhile()

manualRequestWindowUntilOverRequestingSourceByPrefetch

@Test
public void manualRequestWindowUntilOverRequestingSourceByPrefetch()

manualRequestWindowWhileOverRequestingSourceByPrefetch

@Test
public void manualRequestWindowWhileOverRequestingSourceByPrefetch()

windowWhileOneByOneStartingDelimiterReplenishes

@Test
public void windowWhileOneByOneStartingDelimiterReplenishes()

windowWhileUnboundedStartingDelimiterReplenishes

@Test
public void windowWhileUnboundedStartingDelimiterReplenishes()

windowUntilUnboundedStartingDelimiterReplenishes

@Test
public void windowUntilUnboundedStartingDelimiterReplenishes()

discardOnCancelWindowWhile

@Test
public void discardOnCancelWindowWhile()

discardOnCancelWindowUntil

@Test
public void discardOnCancelWindowUntil()

discardOnCancelWindowUntilCutBefore

@Test
public void discardOnCancelWindowUntilCutBefore()

scanOperator

@Test
public void scanOperator()

scanMainSubscriber

@Test
public void scanMainSubscriber()

scanOtherSubscriber

@Test
public void scanOtherSubscriber()