reactor.core.publisher

类 FluxWindowTest

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.FluxWindowTest

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

嵌套类概要

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

FluxOperatorTest.Scenario<I,O>

构造器概要

构造器

构造器和说明
FluxWindowTest()

方法概要

限定符和类型	方法和说明
void	exact()
void	exactBackpressured()
void	exactError()
void	exactWindowCount()
void	overflowQueueNull()
void	overlap()
void	overlapBackpressured()
void	overlapError()
void	processorQueue1Null()
void	processorQueue2Null()
void	scanExactSubscriber()
void	scanOperator()
void	scanOverlapSubscriber()
void	scanOverlapSubscriberLargeBuffered()
void	scanOverlapSubscriberSmallBuffered()
void	scanSkipSubscriber()
void	size1Invalid()
void	size2Invalid()
void	skip()
void	skipBackpressured()
void	skipError()
void	skipInGapError()
void	skipInvalid()
void	source1Null()
void	source2Null()
void	windowWillRerouteAsManyElementAsSpecified()
void	windowWillSubdivideAnInputFlux()
void	windowWillSubdivideAnInputFluxOverlap()

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

构造器详细资料

FluxWindowTest

public FluxWindowTest()

方法详细资料

source1Null

@Test
public void source1Null()

source2Null

@Test
public void source2Null()

processorQueue1Null

@Test
public void processorQueue1Null()

processorQueue2Null

@Test
public void processorQueue2Null()

overflowQueueNull

@Test
public void overflowQueueNull()

size1Invalid

@Test
public void size1Invalid()

size2Invalid

@Test
public void size2Invalid()

skipInvalid

@Test
public void skipInvalid()

exact

@Test
public void exact()

exactBackpressured

@Test
public void exactBackpressured()

exactWindowCount

@Test
public void exactWindowCount()

skip

@Test
public void skip()

skipBackpressured

@Test
public void skipBackpressured()

overlap

@Test
public void overlap()

overlapBackpressured

@Test
public void overlapBackpressured()

exactError

@Test
public void exactError()

skipError

@Test
public void skipError()

skipInGapError

@Test
public void skipInGapError()

overlapError

@Test
public void overlapError()

windowWillSubdivideAnInputFlux

@Test
public void windowWillSubdivideAnInputFlux()

windowWillSubdivideAnInputFluxOverlap

@Test
public void windowWillSubdivideAnInputFluxOverlap()

windowWillRerouteAsManyElementAsSpecified

@Test
public void windowWillRerouteAsManyElementAsSpecified()

scanOperator

@Test
public void scanOperator()

scanExactSubscriber

@Test
public void scanExactSubscriber()

scanOverlapSubscriber

@Test
public void scanOverlapSubscriber()

scanOverlapSubscriberSmallBuffered

@Test
public void scanOverlapSubscriberSmallBuffered()

scanOverlapSubscriberLargeBuffered

@Test
public void scanOverlapSubscriberLargeBuffered()

scanSkipSubscriber

@Test
public void scanSkipSubscriber()