vertx / io.vertx.reactivex.kafka.client.consumer / KafkaConsumer / toFlowable

toFlowable

open fun toFlowable(): Flowable<KafkaConsumerRecord<K, V>>

Overrides ReadStream.toFlowable