Открытие нескольких потоков изменений mongodb в одной Java-программе

Question

Мне нужно иметь два потока изменений на двух отдельных mongodb (часть одного кластера), но я вижу, что watch () блокирует вызов.Любые инструкции после watch () не выполняются.Как открыть еще один поток изменений в том же потоке кода?Пример кода, который у меня есть

MongoClientURI uri = new MongoClientURI("mongodb://localhost:27017");
    MongoClient mclient = new MongoClient(uri);
    final MongoDatabase db = mclient.getDatabase("testdb");
    MongoCollection<Document> infoCollection = db.getCollection("info");

    Consumer<ChangeStreamDocument<Document>> fetchchange = t -> {
      assert t.getFullDocument() != null;
      System.out.println("forEach anonymous class Value::" + t.getFullDocument().get("docu_id"));
    };

    infoCollection.watch().fullDocument(FullDocument.UPDATE_LOOKUP).forEach(fetchchange);

Я прочитал, что есть что-то, называемое «реактивный драйвер» (асинхронный драйвер).Это подход, чтобы решить это?Любые примеры были бы очень полезны