reactor.core.publisher

类 FluxZipTest

java.lang.Object

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

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

reactor.core.publisher.FluxZipTest

public class FluxZipTest
extends FluxOperatorTest<java.lang.String,java.lang.String>

嵌套类概要

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

FluxOperatorTest.Scenario<I,O>

构造器概要

构造器

构造器和说明
FluxZipTest()

方法概要

限定符和类型	方法和说明
void	backpressuredAsyncFusedCancelled()
void	backpressuredAsyncFusedCancelled2()
void	backpressuredAsyncFusedComplete()
void	backpressuredAsyncFusedError()
void	backpressuredAsyncFusedErrorHideAll()
void	cancelled()
void	cancelledHide()
void	createZipWithPrefetch()
void	createZipWithPrefetchIterable()
void	delayedCancelledHide()
void	differentLength()
void	differentLengthOpt()
void	emptyNonEmpty()
void	emptyScalar()
void	failCallable()
void	failCombinedError()
void	failCombinedErrorHide()
void	failCombinedErrorHideAll()
void	failCombinedFusedError()
void	failCombinedNull()
void	failCombinedNullHide()
void	failCombinedNullHideAll()
void	failDoubleErrorSilent()
void	failDoubleNext()
void	failDoubleTerminalPublisher()
void	failIterableCallable()
void	failIterableNull()
void	failNull()
void	failPrefetch()
void	failPrefetchIterable()
void	ignoreDoubleComplete()
void	ignoreRequestZeroHideAll()
void	iterableWithCombinatorHasCorrectLength()
void	moreThan8()
void	moreThan8Hide()
void	multipleIterableStreamValuesCanBeZipped()
void	multipleStreamValuesCanBeZipped()
void	nonEmptyAndEmpty()
void	nonPairWisePairWise()
void	pairWise()
void	pairWise2()
void	pairWise3()
void	prematureCompleteCallableNull()
void	prematureCompleteCallableNullHide()
void	prematureCompleteCallableNullHideAll()
void	prematureCompleteEmpty()
void	prematureCompleteEmptySource()
void	prematureCompleteEmptySourceHide()
void	prematureCompleteIterableCallableNull()
void	prematureCompleteIterableEmpty()
void	prematureCompleteIterableEmptyScalarSource()
void	prematureCompleteSourceEmpty()
void	prematureCompleteSourceEmptyDouble()
void	prematureCompleteSourceError()
void	prematureCompleteSourceErrorHide()
void	publisherOfPublishersUsesCorrectTuple()
void	sameLength()
void	sameLengthBackpressured()
void	sameLengthOptimized()
void	sameLengthOptimizedBackpressured()
void	scalarNonScalar()
void	scalarNonScalarBackpressured()
void	scalarNonScalarOpt()
void	scalarScalar()
void	scanCoordinator()
void	scanInner()
void	scanOperator()
void	scanSingleCoordinator()
void	scanSingleSubscriber()
void	seven()
void	size8LikeInternalBuffer()
void	syncFusionMapToNull()
void	testTwoErrors(boolean firstIsScalar, boolean secondIsScalar, java.lang.String expectedMessage)
void	testTwoErrorsFusion(boolean firstIsFuseable, boolean secondIsFuseable, java.lang.String expectedMessage)
void	zip()
void	zip2()
void	zip3()
void	zip4()
void	zip5()
void	zip6()
void	zip7()
void	zip8()
void	zipEmpty()
void	zipHide()

从类继承的方法 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

构造器详细资料

FluxZipTest

public FluxZipTest()

方法详细资料

testTwoErrors

@CsvSource(value={"false, false, first","true, false, first","false, true, second","true, true, first"})
public void testTwoErrors(boolean firstIsScalar,
                                                                                                                                    boolean secondIsScalar,
                                                                                                                                    java.lang.String expectedMessage)

testTwoErrorsFusion

@CsvSource(value={"false, false, first","true, false, first","false, true, first","true, true, first"})
public void testTwoErrorsFusion(boolean firstIsFuseable,
                                                                                                                                         boolean secondIsFuseable,
                                                                                                                                         java.lang.String expectedMessage)

iterableWithCombinatorHasCorrectLength

@Test
public void iterableWithCombinatorHasCorrectLength()

publisherOfPublishersUsesCorrectTuple

@Test
public void publisherOfPublishersUsesCorrectTuple()

sameLength

@Test
public void sameLength()

sameLengthOptimized

@Test
public void sameLengthOptimized()

sameLengthBackpressured

@Test
public void sameLengthBackpressured()

sameLengthOptimizedBackpressured

@Test
public void sameLengthOptimizedBackpressured()

differentLength

@Test
public void differentLength()

differentLengthOpt

@Test
public void differentLengthOpt()

emptyNonEmpty

@Test
public void emptyNonEmpty()

nonEmptyAndEmpty

@Test
public void nonEmptyAndEmpty()

scalarNonScalar

@Test
public void scalarNonScalar()

scalarNonScalarBackpressured

@Test
public void scalarNonScalarBackpressured()

scalarNonScalarOpt

@Test
public void scalarNonScalarOpt()

scalarScalar

@Test
public void scalarScalar()

emptyScalar

@Test
public void emptyScalar()

syncFusionMapToNull

@Test
public void syncFusionMapToNull()

pairWise

@Test
public void pairWise()

nonPairWisePairWise

@Test
public void nonPairWisePairWise()

pairWise3

@Test
public void pairWise3()

pairWise2

@Test
public void pairWise2()

multipleStreamValuesCanBeZipped

@Test
public void multipleStreamValuesCanBeZipped()

multipleIterableStreamValuesCanBeZipped

@Test
public void multipleIterableStreamValuesCanBeZipped()

zip

@Test
public void zip()

zipEmpty

@Test
public void zipEmpty()

zipHide

@Test
public void zipHide()

zip2

@Test
public void zip2()

zip3

@Test
public void zip3()

zip4

@Test
public void zip4()

zip5

@Test
public void zip5()

zip6

@Test
public void zip6()

zip7

@Test
public void zip7()

zip8

@Test
public void zip8()

createZipWithPrefetch

@Test
public void createZipWithPrefetch()

createZipWithPrefetchIterable

@Test
public void createZipWithPrefetchIterable()

failPrefetch

@Test
public void failPrefetch()

failPrefetchIterable

@Test
public void failPrefetchIterable()

failIterableNull

@Test
public void failIterableNull()

failIterableCallable

@Test
public void failIterableCallable()

prematureCompleteIterableCallableNull

@Test
public void prematureCompleteIterableCallableNull()

prematureCompleteIterableEmptyScalarSource

@Test
public void prematureCompleteIterableEmptyScalarSource()

failDoubleNext

@Test
public void failDoubleNext()

ignoreDoubleComplete

@Test
public void ignoreDoubleComplete()

failDoubleErrorSilent

@Test
public void failDoubleErrorSilent()

failDoubleTerminalPublisher

@Test
public void failDoubleTerminalPublisher()

failNull

@Test
public void failNull()

failCombinedNull

@Test
public void failCombinedNull()

failCombinedNullHide

@Test
public void failCombinedNullHide()

failCombinedNullHideAll

@Test
public void failCombinedNullHideAll()

ignoreRequestZeroHideAll

@Test
public void ignoreRequestZeroHideAll()

failCombinedFusedError

@Test
public void failCombinedFusedError()

backpressuredAsyncFusedCancelled

@Test
public void backpressuredAsyncFusedCancelled()

backpressuredAsyncFusedCancelled2

@Test
public void backpressuredAsyncFusedCancelled2()

backpressuredAsyncFusedError

@Test
public void backpressuredAsyncFusedError()

backpressuredAsyncFusedErrorHideAll

@Test
public void backpressuredAsyncFusedErrorHideAll()

backpressuredAsyncFusedComplete

@Test
public void backpressuredAsyncFusedComplete()

failCombinedError

@Test
public void failCombinedError()

failCombinedErrorHide

@Test
public void failCombinedErrorHide()

failCombinedErrorHideAll

@Test
public void failCombinedErrorHideAll()

failCallable

@Test
public void failCallable()

prematureCompleteCallableNull

@Test
public void prematureCompleteCallableNull()

prematureCompleteCallableNullHide

@Test
public void prematureCompleteCallableNullHide()

prematureCompleteCallableNullHideAll

@Test
public void prematureCompleteCallableNullHideAll()

prematureCompleteEmptySource

@Test
public void prematureCompleteEmptySource()

prematureCompleteEmptySourceHide

@Test
public void prematureCompleteEmptySourceHide()

prematureCompleteSourceEmpty

@Test
public void prematureCompleteSourceEmpty()

prematureCompleteSourceEmptyDouble

@Test
public void prematureCompleteSourceEmptyDouble()

prematureCompleteSourceError

@Test
public void prematureCompleteSourceError()

prematureCompleteSourceErrorHide

@Test
public void prematureCompleteSourceErrorHide()

prematureCompleteEmpty

@Test
public void prematureCompleteEmpty()

prematureCompleteIterableEmpty

@Test
public void prematureCompleteIterableEmpty()

moreThan8

@Test
public void moreThan8()

size8LikeInternalBuffer

@Test
public void size8LikeInternalBuffer()

cancelled

@Test
public void cancelled()

cancelledHide

@Test
public void cancelledHide()

delayedCancelledHide

@Test
public void delayedCancelledHide()

moreThan8Hide

@Test
public void moreThan8Hide()

seven

@Test
public void seven()

scanOperator

@Test
public void scanOperator()

scanCoordinator

@Test
public void scanCoordinator()

scanInner

@Test
public void scanInner()

scanSingleCoordinator

@Test
public void scanSingleCoordinator()

scanSingleSubscriber

@Test
public void scanSingleSubscriber()