reactor.core.publisher

类 FluxBufferWhenTest

java.lang.Object

reactor.core.publisher.FluxBufferWhenTest

public class FluxBufferWhenTest
extends java.lang.Object

构造器概要

构造器

构造器和说明
FluxBufferWhenTest()

方法概要

限定符和类型	方法和说明
void	bufferedCanCompleteIfOpenNeverCompletesDropping()
void	bufferedCanCompleteIfOpenNeverCompletesOverlapping()
void	bufferWillAcumulateMultipleListsOfValuesOverlap()
void	bufferWillSubdivideAnInputFluxGapTime()
void	bufferWillSubdivideAnInputFluxOverlapTime()
void	bufferWillSubdivideAnInputFluxOverlapTime2()
void	bufferWillSubdivideAnInputFluxSameTime()
void	cancelWinsOverDrain()
void	discardOnBoundaryError()
void	discardOnCancel()
void	discardOnCancelPostQueueing()
void	discardOnDrainCancelled()
void	discardOnDrainDoneWithErrors()
void	discardOnDrainEmittedAllCancelled()
void	discardOnDrainEmittedAllWithErrors()
void	discardOnError()
void	discardOnNextWhenNoBuffers()
void	discardOnOpenError()
void	immediateOpen()
void	normal()
void	openCloseBadClose()
void	openCloseBadOpen()
void	openCloseBadSource()
void	openCloseDisposedOnComplete()
void	openCloseEmptyBackpressure()
void	openCloseErrorBackpressure()
void	openCloseLimit()
void	openCloseMainError()
void	openCloseOpenCompletes()
void	openCloseOpenCompletesNoBuffers()
void	openCloseTake()
void	scanOperator()
void	scanStartEndMain()
void	scanStartEndMainCancelled()
void	scanStartEndMainCompleted()
void	scanWhenCloseSubscriber()
void	scanWhenOpenSubscriber()
void	startCompletes()
void	timedOutBuffersDontLeak()

从类继承的方法 java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

FluxBufferWhenTest

public FluxBufferWhenTest()

方法详细资料

bufferedCanCompleteIfOpenNeverCompletesDropping

@Test
 @Tag(value="slow")
public void bufferedCanCompleteIfOpenNeverCompletesDropping()

bufferedCanCompleteIfOpenNeverCompletesOverlapping

@Test
 @Tag(value="slow")
public void bufferedCanCompleteIfOpenNeverCompletesOverlapping()

timedOutBuffersDontLeak

@Test
 @Tag(value="slow")
public void timedOutBuffersDontLeak()
                                                         throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

normal

@Test
public void normal()

startCompletes

@Test
public void startCompletes()

bufferWillAcumulateMultipleListsOfValuesOverlap

@Test
public void bufferWillAcumulateMultipleListsOfValuesOverlap()

bufferWillSubdivideAnInputFluxOverlapTime

@Test
public void bufferWillSubdivideAnInputFluxOverlapTime()

bufferWillSubdivideAnInputFluxOverlapTime2

@Test
public void bufferWillSubdivideAnInputFluxOverlapTime2()

bufferWillSubdivideAnInputFluxSameTime

@Test
public void bufferWillSubdivideAnInputFluxSameTime()

bufferWillSubdivideAnInputFluxGapTime

@Test
public void bufferWillSubdivideAnInputFluxGapTime()

scanOperator

@Test
public void scanOperator()

scanStartEndMain

@Test
public void scanStartEndMain()

scanStartEndMainCancelled

@Test
public void scanStartEndMainCancelled()

scanStartEndMainCompleted

@Test
public void scanStartEndMainCompleted()

scanWhenCloseSubscriber

@Test
public void scanWhenCloseSubscriber()

scanWhenOpenSubscriber

@Test
public void scanWhenOpenSubscriber()

openCloseDisposedOnComplete

@Test
public void openCloseDisposedOnComplete()

openCloseMainError

@Test
public void openCloseMainError()

openCloseBadSource

@Test
public void openCloseBadSource()

openCloseOpenCompletes

@Test
public void openCloseOpenCompletes()

openCloseOpenCompletesNoBuffers

@Test
public void openCloseOpenCompletesNoBuffers()

openCloseTake

@Test
public void openCloseTake()

openCloseLimit

@Test
public void openCloseLimit()

openCloseEmptyBackpressure

@Test
public void openCloseEmptyBackpressure()

openCloseErrorBackpressure

@Test
public void openCloseErrorBackpressure()

openCloseBadOpen

@Test
public void openCloseBadOpen()

openCloseBadClose

@Test
public void openCloseBadClose()

immediateOpen

@Test
public void immediateOpen()

cancelWinsOverDrain

@Test
 @Timeout(value=5L)
public void cancelWinsOverDrain()

discardOnCancel

@Test
public void discardOnCancel()

discardOnCancelPostQueueing

@Test
public void discardOnCancelPostQueueing()

discardOnNextWhenNoBuffers

@Test
public void discardOnNextWhenNoBuffers()

discardOnError

@Test
public void discardOnError()

discardOnDrainCancelled

@Test
public void discardOnDrainCancelled()

discardOnDrainDoneWithErrors

@Test
public void discardOnDrainDoneWithErrors()

discardOnDrainEmittedAllCancelled

@Test
public void discardOnDrainEmittedAllCancelled()

discardOnDrainEmittedAllWithErrors

@Test
public void discardOnDrainEmittedAllWithErrors()

discardOnOpenError

@Test
public void discardOnOpenError()

discardOnBoundaryError

@Test
public void discardOnBoundaryError()