reactor.core.publisher

类 BlockingOptionalMonoSubscriberTest

java.lang.Object

reactor.core.publisher.BlockingOptionalMonoSubscriberTest

public class BlockingOptionalMonoSubscriberTest
extends java.lang.Object

构造器概要

构造器

构造器和说明
BlockingOptionalMonoSubscriberTest()

方法概要

限定符和类型	方法和说明
void	interruptBlock()
void	interruptBlockTimeout()
void	isDisposedBecauseCancelled()
void	isDisposedBecauseComplete()
void	isDisposedBecauseError()
void	isDisposedBecauseValued()
void	optionalEmpty()
void	optionalEmptyDelayed()
void	optionalError()
void	optionalValued()
void	optionalValuedDelayed()
void	scanOperator()
void	timeoutOptionalEmpty()
void	timeoutOptionalError()
void	timeoutOptionalTimingOut()
void	timeoutOptionalValued()

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

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

构造器详细资料

BlockingOptionalMonoSubscriberTest

public BlockingOptionalMonoSubscriberTest()

方法详细资料

optionalValued

@Test
public void optionalValued()

optionalValuedDelayed

@Test
public void optionalValuedDelayed()

optionalEmpty

@Test
public void optionalEmpty()

optionalEmptyDelayed

@Test
public void optionalEmptyDelayed()

optionalError

@Test
public void optionalError()

timeoutOptionalValued

@Test
public void timeoutOptionalValued()

timeoutOptionalEmpty

@Test
public void timeoutOptionalEmpty()

timeoutOptionalError

@Test
public void timeoutOptionalError()

timeoutOptionalTimingOut

@Test
public void timeoutOptionalTimingOut()

isDisposedBecauseCancelled

@Test
public void isDisposedBecauseCancelled()

isDisposedBecauseValued

@Test
public void isDisposedBecauseValued()

isDisposedBecauseComplete

@Test
public void isDisposedBecauseComplete()

isDisposedBecauseError

@Test
public void isDisposedBecauseError()

scanOperator

@Test
public void scanOperator()

interruptBlock

@Test
public void interruptBlock()
                           throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

interruptBlockTimeout

@Test
public void interruptBlockTimeout()
                                  throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException