Fixed bug in VaultServiceRolesInstaller

scalecube · Apr 15, 2021 · d4d6800 · d4d6800
1 parent 75fe1ea
commit d4d6800
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/vault/src/main/java/io/scalecube/security/vault/VaultServiceRolesInstaller.java b/vault/src/main/java/io/scalecube/security/vault/VaultServiceRolesInstaller.java
@@ -166,7 +166,7 @@ public VaultServiceRolesInstaller roleTtl(String roleTtl) {
    * keys) to use it for machine-to-machine authentication.
    */
   public Mono<Void> install() {
-    return Mono.fromRunnable(this::install0)
+    return Mono.defer(this::install0)
         .subscribeOn(Schedulers.boundedElastic())
         .doOnSubscribe(s -> LOGGER.debug("[install] Installing vault service roles"))
         .doOnSuccess(s -> LOGGER.debug("[install][success] Installed vault service roles"))