reactor.core.publisher

类 FluxBufferTimeoutTest

java.lang.Object

reactor.core.publisher.FluxBufferTimeoutTest

public class FluxBufferTimeoutTest
extends java.lang.Object

构造器概要

构造器

构造器和说明
FluxBufferTimeoutTest()

方法概要

限定符和类型	方法和说明
void	bufferWithTimeoutAccumulateOnSize()
void	bufferWithTimeoutAccumulateOnTime()
void	bufferWithTimeoutThrowingExceptionOnTimeOrSizeIfDownstreamDemandIsLow()
void	discardOnCancel()
void	discardOnError()
void	discardOnFlushWithoutRequest()
void	discardOnTimerRejected()
void	downstreamDemandShouldBeAbleToDecreaseOnFullBuffer()
void	downstreamDemandShouldBeAbleToDecreaseOnTimeSpan()
void	exceedingUpstreamDemandResultsInError()
void	flushShouldNotRaceWithNext()
void	rejectedOnNextLeadsToOnError()
void	requestedFromUpstreamShouldNotExceedDownstreamDemand()
void	scanOperator()
void	scanSubscriber()
void	scanSubscriberCancelled()
void	shouldShowActualSubscriberDemand()
void	tearDown()

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

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

构造器详细资料

FluxBufferTimeoutTest

public FluxBufferTimeoutTest()

方法详细资料

tearDown

@AfterEach
public void tearDown()

bufferWithTimeoutAccumulateOnSize

@Test
public void bufferWithTimeoutAccumulateOnSize()

bufferWithTimeoutAccumulateOnTime

@Test
public void bufferWithTimeoutAccumulateOnTime()

bufferWithTimeoutThrowingExceptionOnTimeOrSizeIfDownstreamDemandIsLow

@Test
public void bufferWithTimeoutThrowingExceptionOnTimeOrSizeIfDownstreamDemandIsLow()

scanSubscriber

@Test
public void scanSubscriber()

scanOperator

@Test
public void scanOperator()

shouldShowActualSubscriberDemand

@Test
public void shouldShowActualSubscriberDemand()

downstreamDemandShouldBeAbleToDecreaseOnFullBuffer

@Test
public void downstreamDemandShouldBeAbleToDecreaseOnFullBuffer()

downstreamDemandShouldBeAbleToDecreaseOnTimeSpan

@Test
public void downstreamDemandShouldBeAbleToDecreaseOnTimeSpan()

requestedFromUpstreamShouldNotExceedDownstreamDemand

@Test
public void requestedFromUpstreamShouldNotExceedDownstreamDemand()

exceedingUpstreamDemandResultsInError

@Test
public void exceedingUpstreamDemandResultsInError()

scanSubscriberCancelled

@Test
public void scanSubscriberCancelled()

flushShouldNotRaceWithNext

@Test
public void flushShouldNotRaceWithNext()

rejectedOnNextLeadsToOnError

@Test
public void rejectedOnNextLeadsToOnError()

discardOnCancel

@Test
public void discardOnCancel()

discardOnFlushWithoutRequest

@Test
public void discardOnFlushWithoutRequest()

discardOnTimerRejected

@Test
public void discardOnTimerRejected()

discardOnError

@Test
public void discardOnError()