reactor.core.publisher

类 MonoCallableTest

java.lang.Object

reactor.core.publisher.MonoCallableTest

public class MonoCallableTest
extends java.lang.Object

构造器概要

构造器

构造器和说明
MonoCallableTest()

方法概要

限定符和类型	方法和说明
void	callableCancelledBeforeRun()
void	callableReturnsNull() 回调允许返回 null
void	callableReturnsNullBackpressure()
void	callableReturnsNullShortcircuitsBackpressureSyncFusion()
void	callableSubscribeToCompleteMeasurement()
void	callableThrows() 回调异常会向下传递
void	delegateCall() MonoCallable 异步回调测试,MonoCallable 在 Mono.fromCallable(Callable) 被使用
void	delegateCallError() 测试 Mono.fromCallable(Callable) 抛出异常
void	delegateCallNull() 测试 Mono.fromCallable(Callable) 返回Null,相当于 Mono.empty()
void	normal() 正常的回调
void	normalBackpressured()
void	nullCallable() 回调为空则会抛出空指针异常
void	onMonoEmptyCallableOnBlock() 返回空的回调 block() 测试
void	onMonoErrorCallableOnBlock() 回调里抛出异常 block() 也会抛出异常
void	onMonoSuccessCallableOnBlock() 成功的回到 block() 测试
void	scanOperator()
void	test()

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

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

构造器详细资料

MonoCallableTest

public MonoCallableTest()

方法详细资料

test

@Test
public void test()

nullCallable

@Test
public void nullCallable()

回调为空则会抛出空指针异常

callableReturnsNull

@Test
public void callableReturnsNull()

回调允许返回 null

callableReturnsNullBackpressure

@Test
public void callableReturnsNullBackpressure()

callableReturnsNullShortcircuitsBackpressureSyncFusion

@Test
public void callableReturnsNullShortcircuitsBackpressureSyncFusion()

normal

@Test
public void normal()

正常的回调

normalBackpressured

@Test
public void normalBackpressured()

callableThrows

@Test
public void callableThrows()

回调异常会向下传递

onMonoSuccessCallableOnBlock

@Test
public void onMonoSuccessCallableOnBlock()

成功的回到 block() 测试

onMonoEmptyCallableOnBlock

@Test
public void onMonoEmptyCallableOnBlock()

返回空的回调 block() 测试

onMonoErrorCallableOnBlock

@Test
public void onMonoErrorCallableOnBlock()

回调里抛出异常 block() 也会抛出异常

delegateCall

@Test
public void delegateCall()
                         throws java.lang.Exception

MonoCallable 异步回调测试,MonoCallable 在 Mono.fromCallable(Callable) 被使用

抛出:

java.lang.Exception

delegateCallError

@Test
public void delegateCallError()

测试 Mono.fromCallable(Callable) 抛出异常

delegateCallNull

@Test
public void delegateCallNull()
                             throws java.lang.Exception

测试 Mono.fromCallable(Callable) 返回Null,相当于 Mono.empty()

抛出:

java.lang.Exception

callableCancelledBeforeRun

@Test
public void callableCancelledBeforeRun()

callableSubscribeToCompleteMeasurement

@Test
public void callableSubscribeToCompleteMeasurement()

scanOperator

@Test
public void scanOperator()