diff --git a/vault/src/main/java/io/scalecube/security/vault/VaultServiceRolesInstaller.java b/vault/src/main/java/io/scalecube/security/vault/VaultServiceRolesInstaller.java index 1522455..a0eaa0f 100644 --- 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 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"))