== RxJava 2 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 {@link io.vertx.reactivex.cassandra.CassandraClient} class.
Then use one of the `create` methods to get an instance:

[source,java]
----
{@link examples.RxCassandraClientExamples#createClient(io.vertx.reactivex.core.Vertx)}
----

=== Querying

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

==== Streaming

A {@link io.vertx.reactivex.cassandra.CassandraRowStream} can be converted to a {@link io.reactivex.Flowable}, which is handy when you have to deal with large data sets:

[source,java]
----
{@link examples.RxCassandraClientExamples#simpleQueryStream(io.vertx.reactivex.cassandra.CassandraClient)}
----

==== Bulk fetching

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

[source,java]
----
{@link examples.RxCassandraClientExamples#simpleFullFetch(io.vertx.reactivex.cassandra.CassandraClient)}
----
