RxJava 3 API

The Cassandra client provides an Rxified version of the original API.

Creating an Rxified client

To create an Rxified Cassandra client, make sure to import the CassandraClient class. Then use one of the create methods to get an instance:

`link:../../apidocs/examples/RxCassandraClientExamples.html#createClient-io.vertx.rxjava3.core.Vertx-[createClient]`

Querying

In this section, we will reconsider some of the previous use cases with the Rxified API.

Streaming

A CassandraRowStream can be converted to a Flowable, which is handy when you have to deal with large data sets:

`link:../../apidocs/examples/RxCassandraClientExamples.html#simpleQueryStream-io.vertx.rxjava3.cassandra.CassandraClient-[simpleQueryStream]`

Bulk fetching

When your data set is small, it might be easier to get all results at once:

`link:../../apidocs/examples/RxCassandraClientExamples.html#simpleFullFetch-io.vertx.rxjava3.cassandra.CassandraClient-[simpleFullFetch]`