reactor.core.publisher

类 FluxBufferBoundaryTest

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

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

嵌套类概要

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

FluxOperatorTest.Scenario<I,O>

构造器概要

构造器

构造器和说明
FluxBufferBoundaryTest()

方法概要

限定符和类型	方法和说明
void	bufferSupplierReturnsNUll()
void	bufferSupplierThrows()
void	bufferSupplierThrowsLater()
void	bufferWillAccumulateMultipleListsOfValues()
void	bufferWillSubdivideAnInputFluxTime()
void	bufferWillSubdivideAnInputFluxTime2()
void	discardOnCancel()
void	discardOnEmitOverflow()
void	discardOnError()
void	fluxEmptyBuffer()
void	fluxEmptyBufferJust()
void	mainError()
void	normal()
void	otherError()
void	scanMain()
void	scanOperator()
void	scanOther()
void	scanOtherRequestWhenNoParent()

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

构造器详细资料

FluxBufferBoundaryTest

public FluxBufferBoundaryTest()

方法详细资料

normal

@Test
public void normal()

mainError

@Test
public void mainError()

otherError

@Test
public void otherError()

bufferSupplierThrows

@Test
public void bufferSupplierThrows()

bufferSupplierThrowsLater

@Test
public void bufferSupplierThrowsLater()

bufferSupplierReturnsNUll

@Test
public void bufferSupplierReturnsNUll()

bufferWillSubdivideAnInputFluxTime

@Test
public void bufferWillSubdivideAnInputFluxTime()

bufferWillSubdivideAnInputFluxTime2

@Test
public void bufferWillSubdivideAnInputFluxTime2()

bufferWillAccumulateMultipleListsOfValues

@Test
public void bufferWillAccumulateMultipleListsOfValues()

fluxEmptyBufferJust

@Test
public void fluxEmptyBufferJust()

fluxEmptyBuffer

@Test
public void fluxEmptyBuffer()

scanOperator

@Test
public void scanOperator()

scanMain

@Test
public void scanMain()

scanOther

@Test
public void scanOther()

scanOtherRequestWhenNoParent

@Test
public void scanOtherRequestWhenNoParent()

discardOnCancel

@Test
public void discardOnCancel()

discardOnError

@Test
public void discardOnError()

discardOnEmitOverflow

@Test
public void discardOnEmitOverflow()