reactor.core.publisher

类 FluxTimeoutTest

java.lang.Object

reactor.core.publisher.FluxTimeoutTest

public class FluxTimeoutTest
extends java.lang.Object

构造器概要

构造器

构造器和说明
FluxTimeoutTest()

方法概要

限定符和类型	方法和说明
void	dropsErrorOnCompletedSource()
void	firstElementImmediateResume()
void	firstElementImmediateTimeout()
void	firstTimeoutError()
void	fluxPropagatesErrorUsingAwait()
void	fluxPropagatesErrorUsingAwait2()
void	fluxPropagatesErrorUsingAwait3()
void	fluxTimeoutOther()
void	immediateTimeout()
void	immediateTimeoutResume()
void	itemTimeoutError()
void	itemTimeoutReturnsNull()
void	itemTimeoutThrows()
void	noTimeout()
void	noTimeoutOnInstantSource()
void	oldTimeoutCompleteHasNoEffect()
void	oldTimeoutErrorHasNoEffect()
void	oldTimeoutHasNoEffect()
void	onSubscribeRace()
void	scanMainSubscriber()
void	scanOperator()
void	scanOtherSubscriber()
void	scanTimeoutSubscriber()
void	timeoutCanBeBoundWithCallback()
void	timeoutCanBeBoundWithCallback2()
void	timeoutDropWhenNoCancelWithFallback()
void	timeoutDropWhenNoCancelWithoutFallback()
void	timeoutDurationMessageDefault()
void	timeoutDurationMessageWithName()
void	timeoutNotDurationMessageFirstTimeout()
void	timeoutNotDurationMessageSecondTimeout()
void	timeoutRequested()

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

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

构造器详细资料

FluxTimeoutTest

public FluxTimeoutTest()

方法详细资料

noTimeout

@Test
public void noTimeout()

noTimeoutOnInstantSource

@Test
public void noTimeoutOnInstantSource()

immediateTimeout

@Test
public void immediateTimeout()

firstElementImmediateTimeout

@Test
public void firstElementImmediateTimeout()

immediateTimeoutResume

public void immediateTimeoutResume()

firstElementImmediateResume

@Test
public void firstElementImmediateResume()

oldTimeoutHasNoEffect

@Test
public void oldTimeoutHasNoEffect()

oldTimeoutCompleteHasNoEffect

@Test
public void oldTimeoutCompleteHasNoEffect()

oldTimeoutErrorHasNoEffect

@Test
public void oldTimeoutErrorHasNoEffect()

itemTimeoutThrows

@Test
public void itemTimeoutThrows()

itemTimeoutReturnsNull

@Test
public void itemTimeoutReturnsNull()

dropsErrorOnCompletedSource

@Test
public void dropsErrorOnCompletedSource()

firstTimeoutError

@Test
public void firstTimeoutError()

itemTimeoutError

@Test
public void itemTimeoutError()

timeoutRequested

@Test
public void timeoutRequested()

timeoutCanBeBoundWithCallback

@Test
public void timeoutCanBeBoundWithCallback()

fluxPropagatesErrorUsingAwait

@Test
public void fluxPropagatesErrorUsingAwait()

timeoutCanBeBoundWithCallback2

@Test
public void timeoutCanBeBoundWithCallback2()

fluxPropagatesErrorUsingAwait2

@Test
public void fluxPropagatesErrorUsingAwait2()

fluxPropagatesErrorUsingAwait3

@Test
public void fluxPropagatesErrorUsingAwait3()

fluxTimeoutOther

@Test
public void fluxTimeoutOther()

timeoutDropWhenNoCancelWithoutFallback

@Test
public void timeoutDropWhenNoCancelWithoutFallback()

timeoutDropWhenNoCancelWithFallback

@Test
public void timeoutDropWhenNoCancelWithFallback()

timeoutDurationMessageDefault

@Test
public void timeoutDurationMessageDefault()

timeoutDurationMessageWithName

@Test
public void timeoutDurationMessageWithName()

timeoutNotDurationMessageFirstTimeout

@Test
public void timeoutNotDurationMessageFirstTimeout()

timeoutNotDurationMessageSecondTimeout

@Test
public void timeoutNotDurationMessageSecondTimeout()

onSubscribeRace

@Test
public void onSubscribeRace()

scanOperator

@Test
public void scanOperator()

scanMainSubscriber

@Test
public void scanMainSubscriber()

scanOtherSubscriber

@Test
public void scanOtherSubscriber()

scanTimeoutSubscriber

@Test
public void scanTimeoutSubscriber()