JVMCBC-1163: Update dependencies (part 3)

Core: reactor-core 3.4.24 -> 3.5.0 Change-Id: Ief7cd666bccc8652d71882d8df606f32bf99c7f4 Reviewed-on: https://review.couchbase.org/c/couchbase-jvm-clients/+/183001 Tested-by: Build Bot <build@couchbase.com> Reviewed-by: David Nault <david.nault@couchbase.com>
couchbase · Dec 2, 2022 · 598ed7a · 598ed7a
1 parent 100d373
commit 598ed7a
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
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
@@ -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
@@ -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
@@ -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>