<dependency>
<groupId>org.noear</groupId>
<artifactId>solon-rx</artifactId>
</dependency>
1、描述
基础扩展插件，为 Solon 开发提供最基础的响应式接口支持（复杂的可使用 io.projectreactor 响应式接口）。基于 org.reactivestreams 构建，主要提供接口有：
| 接口 | 扩展自 | 说明 |
|---|
Completable | Publisher<Void> | 可完成发布者 |
CompletableEmitter | | 可完成发射器（一般用于异步构建） |
| | | |
SimpleSubscriber<T> | Subscriber<T> | 简单的订阅者实现 |
SimpleSubscription | Subscription | 简单的订阅实现 |
2、Completable（可完成发布者）接口参考
| 接口 | 说明 | 备注 |
|---|
doOnError(err->{...}) -> self | 出错时 | |
doOnComplete(()->{...}) -> self | 完成时 | |
subscribe() | 订阅（由 doOnError 和 doOnComplete 接收） | |
| | | |
subscribe(emitter:CompletableEmitter) | 订阅（由 emitter 接收） | |
| | | |
subscribe(subscriber:Subscriber) | 订阅（由 subscriber 接收） | |
| | | |
then(otherSupplier:Supplier<Completable>) -> self | 然后（用于多任务编排） | |
then(other:Completable) -> self | 然后（用于多任务编排） | |
| | | |
Completable.create(emitter->{...}) | 创建可完成发布者（通过可完成发射器） | |
Completable.complete() | 创建完成状态的可完成发布者 | |
Completable.create(emitter->{...}) | 创建异常状态的可完成发布者 | |
3、CompletableEmitter（可完成发射器）接口参考
| 接口 | 说明 | 备注 |
|---|
onError(err) | 发射出错事件 | |
onComplete() | 发射完成事件 | |
4、SimpleSubscriber（简单的订阅者）接口参考
| 接口 | 说明 | 备注 |
|---|
doOnSubscribe(subscription->{...}) | 当订阅时 | |
doOnNext(item->bool) | 当下一个时（带中断控制） | |
doOnNext(item->{...}) | 当下一个时 | |
doOnError(err->{...}) | 当出错时 | |
doOnComplete(()->{...}) | 当完成时 | |
5、SimpleSubscription（简单的订阅）接口参考
| 接口 | 说明 | 备注 |
|---|
onRequest((subscription, l)->{...}) | 当请求时 | |
Solon