From 3da378e4561155c04d97494087f7578c01ae05c0 Mon Sep 17 00:00:00 2001
From: Joan Ruget <joan.ruget@gmail.com>
Date: Tue, 25 Oct 2022 22:30:05 +0200
Subject: [PATCH] Correct missing watch database in reactive mongodb client

---
 .../java/io/quarkus/mongodb/impl/ReactiveMongoDatabaseImpl.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/extensions/mongodb-client/runtime/src/main/java/io/quarkus/mongodb/impl/ReactiveMongoDatabaseImpl.java b/extensions/mongodb-client/runtime/src/main/java/io/quarkus/mongodb/impl/ReactiveMongoDatabaseImpl.java
index fc99cdeebcb6e..41249cdf9f7ba 100644
--- a/extensions/mongodb-client/runtime/src/main/java/io/quarkus/mongodb/impl/ReactiveMongoDatabaseImpl.java
+++ b/extensions/mongodb-client/runtime/src/main/java/io/quarkus/mongodb/impl/ReactiveMongoDatabaseImpl.java
@@ -208,7 +208,7 @@ public Multi<ChangeStreamDocument<Document>> watch() {
 
     @Override
     public Multi<ChangeStreamDocument<Document>> watch(ChangeStreamOptions options) {
-        return null;
+        return Wrappers.toMulti(apply(options, database.watch()));
     }
 
     @Override