Im trying to work with the reactive streams MongoDB API for Java. So first I created a MongoClient as said in the documentation (http://mongodb.github.io/mongo-java-driver-reactivestreams/1.11/getting-started/)

Here I replaced my connection string.

MongoClient client = MongoClients.create("connection-string");

It is connecting perfectly fine but I can not find a Publisher that calls a Subscriber when the connection is ready.

I cant just write code below this because this is async.

//Async
MongoClient client = MongoClients.create("connection-string");
//Some code - Is executed to early

I can not imagine that it is not possible to wait for the connection to establishe.

0 Answers