reactor.core.publisher

类 MonoDelayElementTest

java.lang.Object

reactor.core.publisher.MonoDelayElementTest

public class MonoDelayElementTest
extends java.lang.Object

构造器概要

构造器

构造器和说明
MonoDelayElementTest()

方法概要

限定符和类型	方法和说明
void	cancelBeforeNext()
void	cancelDuringDelay()
void	cancelUpstreamOnceWhenCancelled()
void	cancelUpstreamOnceWhenRejected()
void	completeOnNextWithoutCancel()
void	emptyIsImmediate()
void	errorAfterNextIsNeverTriggered()
void	errorIsImmediate()
void	guardedAgainstMultipleOnNext()
void	guardedAgainstOnComplete()
void	guardedAgainstOnError()
void	monoApiTestDuration()
void	monoApiTestMillis()
void	monoApiTestMillisAndTimer()
void	neverCancelUpstreamWhenValueResolvedOnce()
void	normalIsDelayed()
void	onNextOnDisposedSchedulerThrows()
void	scanOperator()
void	scanSubscriber()
void	subMillisDelay()
void	upstreamIsDelayedSource()

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

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

构造器详细资料

MonoDelayElementTest

public MonoDelayElementTest()

方法详细资料

normalIsDelayed

@Test
public void normalIsDelayed()

subMillisDelay

@Test
public void subMillisDelay()

cancelDuringDelay

@Test
public void cancelDuringDelay()

cancelBeforeNext

@Test
public void cancelBeforeNext()

emptyIsImmediate

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

errorIsImmediate

@Test
public void errorIsImmediate()

errorAfterNextIsNeverTriggered

@Test
public void errorAfterNextIsNeverTriggered()

onNextOnDisposedSchedulerThrows

@Test
public void onNextOnDisposedSchedulerThrows()

cancelUpstreamOnceWhenCancelled

@Test
public void cancelUpstreamOnceWhenCancelled()

neverCancelUpstreamWhenValueResolvedOnce

@Test
public void neverCancelUpstreamWhenValueResolvedOnce()

cancelUpstreamOnceWhenRejected

@Test
public void cancelUpstreamOnceWhenRejected()

monoApiTestDuration

@Test
public void monoApiTestDuration()

monoApiTestMillis

@Test
public void monoApiTestMillis()

monoApiTestMillisAndTimer

@Test
public void monoApiTestMillisAndTimer()

guardedAgainstMultipleOnNext

@Test
public void guardedAgainstMultipleOnNext()

guardedAgainstOnComplete

@Test
public void guardedAgainstOnComplete()

guardedAgainstOnError

@Test
public void guardedAgainstOnError()

upstreamIsDelayedSource

@Test
public void upstreamIsDelayedSource()

completeOnNextWithoutCancel

@Test
public void completeOnNextWithoutCancel()

scanOperator

@Test
public void scanOperator()

scanSubscriber

@Test
public void scanSubscriber()