Нет API на основе реактивных потоков. Существует модуль Vert.x Reactive Streams, который просто соединяет Vert.x ReadStream
с Reactive Streams Publisher
и WriteStream
с Subscriber
.
Ядро Vert.x, а также все модули в стеке имеют API Rxified . Это означает, что все методы, работающие с обратными вызовами, будут возвращать Single
, Completable
или Maybe
. ReadStream
можно преобразовать в Flowable
или Observable
.
Несколько методов из API-интерфейса ядра и модулей Vert.x недоступны в Rxified API, но вы можете легко преобразовать объект Rxified Vert.x в его базовый аналог с методом getDelegate
.