MonoCreateTest (reactor-3)

java.lang.Object
- reactor.core.publisher.MonoCreateTest

public class MonoCreateTest
extends java.lang.Object

构造器概要

构造器
构造器和说明

MonoCreateTest()

构造器
构造器和说明
`MonoCreateTest()`

方法概要

所有方法实例方法具体方法
限定符和类型	方法和说明
`void`	`cancellation()` 取消订阅测试，验证onDispose在订阅者取消时触发
`void`	`createStreamFromMonoCreate()` 使用 create 函数自定义逻辑创建一个Mono
`void`	`createStreamFromMonoCreate2()` 方法引用形式创建一个空的Mono
`void`	`createStreamFromMonoCreateError()` 在创建流时使用MonoSink主动抛出一个异常，验证onDispose在发生异常时触发
`void`	`createStreamFromMonoCreateHide()` 创建一个隐藏流
`void`	`delayUntilTriggerProviderThrows()` 延迟发布，如果 delayUntil 里抛出异常，即时发布已一个消息，异常还是向下传递
`void`	`ensuresElementsIsDiscarded()`
`void`	`monoCreateCancelOnNext()` 测试当元素发布后再取消订阅 onCancel 不生效
`void`	`monoCreateDisposables()` 验证 onDispose 事件可以重复注册
`void`	`monoCreateOnCancel()`
`void`	`monoCreateOnRequest()` PULL方式创建Mono, 这种具有懒加载思想，等待订阅者发起请求触发 onRequest 发布元素
`void`	`monoFirstCancelThenOnCancel()` 订阅者取消订阅触发 onCancel 测试
`void`	`monoFirstCancelThenOnDispose()` 订阅者取消订阅触发 onDispose 测试
`void`	`onRequest()` 背压数 n 默认是Long.MAX_VALUE
`void`	`onRequestDeferred()` 背压数最小为1
`void`	`scanDefaultMonoSink()`
`void`	`scanDefaultMonoSinkCancelTerminates()` 扫描 MonoSink 取消内省值
`void`	`scanOperator()` MonoCreate 是异步的
`void`	`sinkApiEmptySuccessAfterEmptySuccessIsIgnored()` MonoSink 发布空消息后，会忽略后面发布的空消息
`void`	`sinkApiEmptySuccessAfterErrorIsIgnored()` MonoSink 在发布异常后会忽略后面空元素的发布
`void`	`sinkApiEmptySuccessAfterSuccessIsIgnored()` MonoSink 发布成功后会忽略后面的空发布
`void`	`sinkApiErrorAfterEmptySuccessBubblesAndDrops()` MonoSink 如果在成功发布消息后再抛出异常，则会忽略异常
`void`	`sinkApiErrorAfterErrorBubblesAndDrops()` MonoSink 在发布一个异常后会忽略后面异常的发布
`void`	`sinkApiErrorAfterSuccessBubblesAndDrops()` MonoSink 在发布消息后会忽略后面异常的发布
`void`	`sinkApiSuccessAfterEmptySuccessIsIgnored()` MonoSink 发布空的消息成功后续发布的消息会被忽略
`void`	`sinkApiSuccessAfterErrorIsIgnored()` MonoSink 在发布异常后会忽略后面元素的发布
`void`	`sinkApiSuccessAfterSuccessIsIgnored()` MonoSink 在发布第一条非空消息后会忽略后面发布的非空消息
`void`	`sinkToString()` MonoSink toString 返回 MonoSink字符串

从类继承的方法 java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- 构造器详细资料
  - MonoCreateTest
```
public MonoCreateTest()
```
- 方法详细资料
  - createStreamFromMonoCreate
```
@Test
public void createStreamFromMonoCreate()
```
    使用 create 函数自定义逻辑创建一个Mono
  - createStreamFromMonoCreateHide
```
@Test
public void createStreamFromMonoCreateHide()
```
    创建一个隐藏流
  - createStreamFromMonoCreateError
```
@Test
public void createStreamFromMonoCreateError()
```
    在创建流时使用MonoSink主动抛出一个异常，验证onDispose在发生异常时触发
  - cancellation
```
@Test
public void cancellation()
```
    取消订阅测试，验证onDispose在订阅者取消时触发
  - monoCreateDisposables
```
@Test
public void monoCreateDisposables()
```
    验证 onDispose 事件可以重复注册
  - monoCreateOnCancel
```
@Test
public void monoCreateOnCancel()
```
  - monoCreateCancelOnNext
```
@Test
public void monoCreateCancelOnNext()
```
    测试当元素发布后再取消订阅 onCancel 不生效
  - monoFirstCancelThenOnCancel
```
@Test
public void monoFirstCancelThenOnCancel()
```
    订阅者取消订阅触发 onCancel 测试
  - monoFirstCancelThenOnDispose
```
@Test
public void monoFirstCancelThenOnDispose()
```
    订阅者取消订阅触发 onDispose 测试
  - createStreamFromMonoCreate2
```
@Test
public void createStreamFromMonoCreate2()
```
    方法引用形式创建一个空的Mono
  - monoCreateOnRequest
```
@Test
public void monoCreateOnRequest()
```
    PULL方式创建Mono, 这种具有懒加载思想，等待订阅者发起请求触发 onRequest 发布元素
  - sinkApiEmptySuccessAfterEmptySuccessIsIgnored
```
@Test
public void sinkApiEmptySuccessAfterEmptySuccessIsIgnored()
```
    MonoSink 发布空消息后，会忽略后面发布的空消息
  - sinkApiSuccessAfterEmptySuccessIsIgnored
```
@Test
public void sinkApiSuccessAfterEmptySuccessIsIgnored()
```
    MonoSink 发布空的消息成功后续发布的消息会被忽略
  - sinkApiErrorAfterEmptySuccessBubblesAndDrops
```
@Test
public void sinkApiErrorAfterEmptySuccessBubblesAndDrops()
```
    MonoSink 如果在成功发布消息后再抛出异常，则会忽略异常
  - sinkApiEmptySuccessAfterSuccessIsIgnored
```
@Test
public void sinkApiEmptySuccessAfterSuccessIsIgnored()
```
    MonoSink 发布成功后会忽略后面的空发布
  - sinkApiSuccessAfterSuccessIsIgnored
```
@Test
public void sinkApiSuccessAfterSuccessIsIgnored()
```
    MonoSink 在发布第一条非空消息后会忽略后面发布的非空消息
  - sinkApiErrorAfterSuccessBubblesAndDrops
```
@Test
public void sinkApiErrorAfterSuccessBubblesAndDrops()
```
    MonoSink 在发布消息后会忽略后面异常的发布
  - sinkApiEmptySuccessAfterErrorIsIgnored
```
@Test
public void sinkApiEmptySuccessAfterErrorIsIgnored()
```
    MonoSink 在发布异常后会忽略后面空元素的发布
  - sinkApiSuccessAfterErrorIsIgnored
```
@Test
public void sinkApiSuccessAfterErrorIsIgnored()
```
    MonoSink 在发布异常后会忽略后面元素的发布
  - sinkApiErrorAfterErrorBubblesAndDrops
```
@Test
public void sinkApiErrorAfterErrorBubblesAndDrops()
```
    MonoSink 在发布一个异常后会忽略后面异常的发布
  - delayUntilTriggerProviderThrows
```
@Test
public void delayUntilTriggerProviderThrows()
```
    延迟发布，如果 delayUntil 里抛出异常，即时发布已一个消息，异常还是向下传递
  - scanOperator
```
@Test
public void scanOperator()
```
    MonoCreate 是异步的
  - scanDefaultMonoSink
```
@Test
public void scanDefaultMonoSink()
```
  - scanDefaultMonoSinkCancelTerminates
```
@Test
public void scanDefaultMonoSinkCancelTerminates()
```
    扫描 MonoSink 取消内省值
  - ensuresElementsIsDiscarded
```
@Test
public void ensuresElementsIsDiscarded()
```
  - sinkToString
```
@Test
public void sinkToString()
```
    MonoSink toString 返回 MonoSink字符串
  - onRequest
```
@Test
public void onRequest()
```
    背压数 n 默认是Long.MAX_VALUE
  - onRequestDeferred
```
@Test
public void onRequestDeferred()
```
    背压数最小为1

类 MonoCreateTest

构造器概要

方法概要

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

构造器详细资料

MonoCreateTest

方法详细资料

createStreamFromMonoCreate

createStreamFromMonoCreateHide

createStreamFromMonoCreateError

cancellation

monoCreateDisposables

monoCreateOnCancel

monoCreateCancelOnNext

monoFirstCancelThenOnCancel

monoFirstCancelThenOnDispose

createStreamFromMonoCreate2

monoCreateOnRequest

sinkApiEmptySuccessAfterEmptySuccessIsIgnored

sinkApiSuccessAfterEmptySuccessIsIgnored

sinkApiErrorAfterEmptySuccessBubblesAndDrops

sinkApiEmptySuccessAfterSuccessIsIgnored

sinkApiSuccessAfterSuccessIsIgnored

sinkApiErrorAfterSuccessBubblesAndDrops

sinkApiEmptySuccessAfterErrorIsIgnored

sinkApiSuccessAfterErrorIsIgnored

sinkApiErrorAfterErrorBubblesAndDrops

delayUntilTriggerProviderThrows

scanOperator

scanDefaultMonoSink

scanDefaultMonoSinkCancelTerminates

ensuresElementsIsDiscarded

sinkToString

onRequest

onRequestDeferred