Vert.x RxJava 和反应流 API
Vert.x RxJava and Reactive Streams API
我是 Vert.x 的新手,目前正在探索它。我发现在vert.x3中有3种使用方式
1) 使用法线顶点API
2) 使用基于 RxJava API
3) 使用基于 API
的反应流
我想知道在 RxJava 和 Reactive Streams 中是否所有的顶点模块都可用 API 或者还有一些模块的反应版本不可用?
另外,针对#1 使用#2 或#3 的缺点是什么?
没有基于反应流的 API。有一个 Vert.x Reactive Streams 模块,它只是将 Vert.x ReadStream
与 Reactive Streams Publisher
以及 WriteStream
与 Subscriber
.[=22 桥接起来=]
Vert.x 内核以及堆栈中的所有模块都有一个 Rxified API。这意味着所有使用回调的方法都将 return a Single
、Completable
或 Maybe
。 ReadStream
可以转换为 Flowable
或 Observable
.
Vert.x 核心和模块 API 中的一些方法在 Rxified API 中不可用,但您可以轻松转换一个 Rxified Vert.x 对象到它的核心对象 getDelegate
方法。
我是 Vert.x 的新手,目前正在探索它。我发现在vert.x3中有3种使用方式 1) 使用法线顶点API 2) 使用基于 RxJava API 3) 使用基于 API
的反应流我想知道在 RxJava 和 Reactive Streams 中是否所有的顶点模块都可用 API 或者还有一些模块的反应版本不可用? 另外,针对#1 使用#2 或#3 的缺点是什么?
没有基于反应流的 API。有一个 Vert.x Reactive Streams 模块,它只是将 Vert.x ReadStream
与 Reactive Streams Publisher
以及 WriteStream
与 Subscriber
.[=22 桥接起来=]
Vert.x 内核以及堆栈中的所有模块都有一个 Rxified API。这意味着所有使用回调的方法都将 return a Single
、Completable
或 Maybe
。 ReadStream
可以转换为 Flowable
或 Observable
.
Vert.x 核心和模块 API 中的一些方法在 Rxified API 中不可用,但您可以轻松转换一个 Rxified Vert.x 对象到它的核心对象 getDelegate
方法。