Vert.x RxJava and Reactive Streams API

Question

I am new to Vert.x and currently exploring it. I found that in vert.x 3 there are three ways to use 1) Using normal vertex API 2) Using RxJava based API 3) Using Reactive Streams based API

I want to know whether all vertex modules are available in RxJava and Reactive Streams API or there are still some modules where reactive version is not available? Also what can be the shortcomings of using either #2 or #3 against #1?

tsegismont · Accepted Answer · 2018-09-12 10:23:49Z

1

There is no Reactive Streams based API. There is a Vert.x Reactive Streams module, which simply bridges Vert.x ReadStream with Reactive Streams Publisher, and WriteStream with Subscriber.

Vert.x core as well as all modules in the stack have an Rxified API. This means all methods working with callbacks will either return a Single, Completable or Maybe. ReadStream can be converted to Flowable or Observable.

A few methods from the Vert.x core and modules API are not available in the Rxified API, but you can easily convert an Rxified Vert.x object to its core counterpart with getDelegate method.

answered Sep 12, 2018 at 10:23

tsegismont

9,2831 gold badge19 silver badges29 bronze badges

Sign up to request clarification or add additional context in comments.

2 Comments

Punit Goel Over a year ago

I could see that for eg AMQP Bridge, there are two options in reactive way one is io.vertx.reactivex.amqpbridge or other is io.vertx.rxjava.amqpbridge . I wanted to know the differences in using either of these

tsegismont Over a year ago

The former is the RxJava2 API, the latter RxJava1

Collectives™ on Stack Overflow

Vert.x RxJava and Reactive Streams API

1 Answer 1

2 Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

2 Comments

Your Answer

Sign up or log in

Post as a guest

Related