JVMCBC-1699 launchSeedNodeResolver logs scary warning

Modifications
-------------
Don't retry publishing seed nodes if the cluster shuts down
before the seed nodes are resolved.

Change-Id: I01bdddec5b2979ef6a9637f09f750f2ed51cba7b
Reviewed-on: https://review.couchbase.org/c/couchbase-jvm-clients/+/235241
Reviewed-by: Michael Reiche <[email protected]>
Tested-by: Build Bot <[email protected]>
(cherry picked from commit f02e126)
Reviewed-on: https://review.couchbase.org/c/couchbase-jvm-clients/+/235257
Reviewed-by: David Nault <[email protected]>

Author: dnault

core-io/src/main/java/com/couchbase/client/core/Reactor.java

@@ -285,7 +285,8 @@ public static <T> Flux<T> shieldFromCancellation(Flux<T> flux) {
     });
   }
 
-  private static Sinks.EmitResult ignoreIfDone(Sinks.EmitResult result) {
+  @Stability.Internal
+  public static Sinks.EmitResult ignoreIfDone(Sinks.EmitResult result) {
     return result == FAIL_TERMINATED || result == FAIL_CANCELLED
       ? OK
       : result;

core-io/src/main/java/com/couchbase/client/core/config/DefaultConfigurationProvider.java

@@ -97,6 +97,7 @@
 import java.util.stream.Collectors;
 
 import static com.couchbase.client.core.Reactor.emitFailureHandler;
+import static com.couchbase.client.core.Reactor.ignoreIfDone;
 import static com.couchbase.client.core.logging.RedactableArgument.redactMeta;
 import static com.couchbase.client.core.logging.RedactableArgument.redactSystem;
 import static com.couchbase.client.core.util.ConnectionStringUtil.fromDnsSrvOrThrowIfTlsRequired;
@@ -230,7 +231,7 @@ private Disposable launchSeedNodeResolver(ConnectionString connectionString, Cor
           env.eventBus()
         );
         topologyParser = createTopologyParser(core.environment(), seedNodes);
-        setSeedNodes(seedNodes).orThrow();
+        ignoreIfDone(setSeedNodes(seedNodes)).orThrow();
         log.info("Resolved seed nodes: {}", redactSystem(seedNodes));
       })
       .subscribeOn(Schedulers.boundedElastic()) // DNS SRV lookup blocks