RxJava 3 API
The Mongo client provides an Rxified version of the original API.
Creating an Rxified client
To create an Rxified Mongo client, make sure to import the MongoClient
class.
Then use one of the create
methods to get an instance:
`link:../../apidocs/examples/RxMongoClientExamples.html#createClient-io.vertx.rxjava3.core.Vertx-io.vertx.core.json.JsonObject-[createClient]`
Finding documents in batches
A ReadStream
can be converted to a Flowable
, which is handy when you have to deal with large data sets:
`link:../../apidocs/examples/RxMongoClientExamples.html#findBatch-io.vertx.rxjava3.ext.mongo.MongoClient-[findBatch]`