JCBC-2167 (followup) Reactive API: publish on configurable scheduler

Publish ReactiveCluster.disconnect() completion on the user scheduler. Change-Id: I9a47a47f9b0c640ff93d66203f01c36ac9c8c840 Reviewed-on: https://review.couchbase.org/c/couchbase-jvm-clients/+/219007 Tested-by: Build Bot <[email protected]> Reviewed-by: Michael Reiche <[email protected]>
couchbase · Nov 1, 2024 · dcc5f18 · dcc5f18
1 parent d8c838f
commit dcc5f18
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/java-client/src/main/java/com/couchbase/client/java/ReactiveCluster.java b/java-client/src/main/java/com/couchbase/client/java/ReactiveCluster.java
@@ -32,8 +32,8 @@
 import com.couchbase.client.core.error.context.ReducedAnalyticsErrorContext;
 import com.couchbase.client.core.error.context.ReducedQueryErrorContext;
 import com.couchbase.client.core.error.context.ReducedSearchErrorContext;
-import com.couchbase.client.core.util.ReactorOps;
 import com.couchbase.client.core.util.ConnectionString;
+import com.couchbase.client.core.util.ReactorOps;
 import com.couchbase.client.java.analytics.AnalyticsAccessor;
 import com.couchbase.client.java.analytics.AnalyticsOptions;
 import com.couchbase.client.java.analytics.ReactiveAnalyticsResult;
@@ -426,7 +426,7 @@ public Mono<Void> disconnect() {
    * @param timeout overriding the default disconnect timeout if needed.
    */
   public Mono<Void> disconnect(final Duration timeout) {
-    return asyncCluster.disconnectInternal(timeout);
+    return reactor.publishOnUserScheduler(asyncCluster.disconnectInternal(timeout));
   }
 
   /**