reactor.core.publisher

类 FluxOnBackpressureBufferTest

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

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

嵌套类概要

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

FluxOperatorTest.Scenario<I,O>

构造器概要

构造器

构造器和说明
FluxOnBackpressureBufferTest()

方法概要

限定符和类型	方法和说明
void	bufferOverflowErrorDelayed()
void	failNegativeHistory()
void	gh1666_bufferNine()
void	gh1666_bufferThree()
void	onBackpressureBuffer()
void	onBackpressureBufferMax()
void	onBackpressureBufferMaxCallback()
void	onBackpressureBufferMaxCallbackSourceEmitsAfterComplete()
void	onBackpressureBufferMaxCallbackUnder8()
void	scanCapacityBoundedQueueWithExactCapacity()
void	scanCapacityBoundedQueueWithExtraCapacity()
void	scanCapacityUnbounded()
void	scanOperator()
void	scanSubscriber()
void	stepByStepRequesting()

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

构造器详细资料

FluxOnBackpressureBufferTest

public FluxOnBackpressureBufferTest()

方法详细资料

bufferOverflowErrorDelayed

@Test
public void bufferOverflowErrorDelayed()

failNegativeHistory

@Test
public void failNegativeHistory()

onBackpressureBuffer

@Test
public void onBackpressureBuffer()

onBackpressureBufferMax

@Test
public void onBackpressureBufferMax()

onBackpressureBufferMaxCallback

@Test
public void onBackpressureBufferMaxCallback()

onBackpressureBufferMaxCallbackUnder8

@Test
public void onBackpressureBufferMaxCallbackUnder8()

onBackpressureBufferMaxCallbackSourceEmitsAfterComplete

@Test
public void onBackpressureBufferMaxCallbackSourceEmitsAfterComplete()

stepByStepRequesting

@Test
public void stepByStepRequesting()

gh1666_bufferThree

@Test
public void gh1666_bufferThree()

gh1666_bufferNine

@Test
public void gh1666_bufferNine()

scanOperator

@Test
public void scanOperator()

scanSubscriber

@Test
public void scanSubscriber()

scanCapacityUnbounded

@Test
public void scanCapacityUnbounded()

scanCapacityBoundedQueueWithExactCapacity

@Test
public void scanCapacityBoundedQueueWithExactCapacity()

scanCapacityBoundedQueueWithExtraCapacity

@Test
public void scanCapacityBoundedQueueWithExtraCapacity()