diff --git a/core-io/src/main/java/com/couchbase/client/core/transaction/util/MonoBridge.java b/core-io/src/main/java/com/couchbase/client/core/transaction/util/MonoBridge.java
index 1e113032c..2ca59ac24 100644
--- a/core-io/src/main/java/com/couchbase/client/core/transaction/util/MonoBridge.java
+++ b/core-io/src/main/java/com/couchbase/client/core/transaction/util/MonoBridge.java
@@ -79,7 +79,7 @@ public MonoBridge(Mono<T> feedFrom, String dbg, Object syncer, @Nullable CoreTra
                             // Even though a Mono still need to propagate onComplete in case it's Mono<Void>
                             if (!done) {
                                 if (logger != null) logger.info("", "MB: [%s] propagating complete", dbg);
-                                actual.tryEmitValue(null);
+                                actual.tryEmitEmpty();
                             } else if (logger != null)
                                 logger.info("", "MB: [%s] skipping complete propagating as done", dbg);
                         });
diff --git a/core-io/src/main/java/com/couchbase/client/core/transaction/util/ReactiveWaitGroup.java b/core-io/src/main/java/com/couchbase/client/core/transaction/util/ReactiveWaitGroup.java
index 30a54ad11..89f71cb45 100644
--- a/core-io/src/main/java/com/couchbase/client/core/transaction/util/ReactiveWaitGroup.java
+++ b/core-io/src/main/java/com/couchbase/client/core/transaction/util/ReactiveWaitGroup.java
@@ -96,7 +96,7 @@ public Mono<Void> done(Waiter waiter) {
 
             // Signal the awaiter, making sure to do it outside synchronization for safety.
             if (notifier != null) {
-                notifier.tryEmitValue(null).orThrow();
+                notifier.tryEmitEmpty().orThrow();
             }
 
             return Mono.empty();
diff --git a/pom.xml b/pom.xml
index de9588ef1..12cce6e00 100644
--- a/pom.xml
+++ b/pom.xml
@@ -29,7 +29,7 @@
         <log4j-slf4j-impl.version>2.19.0</log4j-slf4j-impl.version>
 
         <jackson.version>2.14.0</jackson.version>
-        <reactor.version>3.4.24</reactor.version>
+        <reactor.version>3.5.0</reactor.version>
         <reactive-streams.version>1.0.4</reactive-streams.version>
         <blockhound.version>1.0.6.RELEASE</blockhound.version>
         <log4j.version>1.2.17</log4j.version>