vertx / io.vertx.reactivex.core.eventbus / MessageConsumer / toFlowable

toFlowable

open fun toFlowable(): Flowable<Message<T>>

Overrides ReadStream.toFlowable