reactor.core.publisher

类 FluxBufferTest

java.lang.Object

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

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

reactor.core.publisher.FluxBufferTest

public class FluxBufferTest
extends FluxOperatorTest<java.lang.String,java.util.List<java.lang.String>>

嵌套类概要

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

FluxOperatorTest.Scenario<I,O>

构造器概要

构造器

构造器和说明
FluxBufferTest()

方法概要

限定符和类型	方法和说明
void	bufferWillRerouteAsManyElementAsSpecified()
void	bufferWillSubdivideAnInputFlux()
void	bufferWillSubdivideAnInputFluxOverlap()
void	discardOnCancel()
void	discardOnCancelOverlap()
void	discardOnCancelSkip()
void	discardOnError()
void	discardOnErrorOverlap()
void	discardOnErrorSkip()
void	discardOnNextSupplierError()
void	discardOnNextSupplierErrorOverlap()
void	discardOnNextSupplierErrorSkip()
void	discardOnSkippedElements()
void	largerSkip()
void	largerSkipBackpressured()
void	largerSkipEven()
void	largerSkipEvenBackpressured()
void	normalExact()
void	normalExactBackpressured()
void	scanExactSubscriber()
void	scanOperator()
void	scanOverlappingSubscriber()
void	scanOverlappingSubscriberCancelled()
void	scanSkipSubscriber()
void	sizeZero()
void	skipZero()
void	smallerSkip()
void	smallerSkip3Backpressured()
void	smallerSkipBackpressured()
void	sourceNull()
void	supplierNull()
void	supplierReturnsNull()
void	supplierThrows()

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

构造器详细资料

FluxBufferTest

public FluxBufferTest()

方法详细资料

sourceNull

@Test
public void sourceNull()

supplierNull

@Test
public void supplierNull()

sizeZero

@Test
public void sizeZero()

skipZero

@Test
public void skipZero()

normalExact

@Test
public void normalExact()

normalExactBackpressured

@Test
public void normalExactBackpressured()

largerSkip

@Test
public void largerSkip()

largerSkipEven

@Test
public void largerSkipEven()

largerSkipEvenBackpressured

@Test
public void largerSkipEvenBackpressured()

largerSkipBackpressured

@Test
public void largerSkipBackpressured()

smallerSkip

@Test
public void smallerSkip()

smallerSkipBackpressured

@Test
public void smallerSkipBackpressured()

smallerSkip3Backpressured

@Test
public void smallerSkip3Backpressured()

supplierReturnsNull

@Test
public void supplierReturnsNull()

supplierThrows

@Test
public void supplierThrows()

bufferWillSubdivideAnInputFlux

@Test
public void bufferWillSubdivideAnInputFlux()

bufferWillSubdivideAnInputFluxOverlap

@Test
public void bufferWillSubdivideAnInputFluxOverlap()

bufferWillRerouteAsManyElementAsSpecified

@Test
public void bufferWillRerouteAsManyElementAsSpecified()

scanOperator

@Test
public void scanOperator()

scanExactSubscriber

@Test
public void scanExactSubscriber()

scanOverlappingSubscriber

@Test
public void scanOverlappingSubscriber()

scanOverlappingSubscriberCancelled

@Test
public void scanOverlappingSubscriberCancelled()

scanSkipSubscriber

@Test
public void scanSkipSubscriber()

discardOnCancel

@Test
public void discardOnCancel()

discardOnCancelSkip

@Test
public void discardOnCancelSkip()

discardOnCancelOverlap

@Test
public void discardOnCancelOverlap()

discardOnNextSupplierError

@Test
public void discardOnNextSupplierError()

discardOnNextSupplierErrorSkip

@Test
public void discardOnNextSupplierErrorSkip()

discardOnNextSupplierErrorOverlap

@Test
public void discardOnNextSupplierErrorOverlap()

discardOnSkippedElements

@Test
public void discardOnSkippedElements()

discardOnError

@Test
public void discardOnError()

discardOnErrorSkip

@Test
public void discardOnErrorSkip()

discardOnErrorOverlap

@Test
public void discardOnErrorOverlap()