Skip to content

Commit d1e2c2f

Browse files
committed
Removed .subscribeOn(Schedulers.boundedElastic()) from vault token suppliers
1 parent ace8bd4 commit d1e2c2f

File tree

2 files changed

+0
-4
lines changed

2 files changed

+0
-4
lines changed

vault/src/main/java/io/scalecube/security/vault/VaultClientTokenSupplier.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,6 @@
1212
import org.slf4j.Logger;
1313
import org.slf4j.LoggerFactory;
1414
import reactor.core.publisher.Mono;
15-
import reactor.core.scheduler.Schedulers;
1615

1716
public final class VaultClientTokenSupplier {
1817

@@ -88,7 +87,6 @@ public VaultClientTokenSupplier vaultRole(String vaultRole) {
8887
public Mono<String> getToken() {
8988
return Mono.fromRunnable(this::validate)
9089
.then(Mono.fromCallable(this::getToken0))
91-
.subscribeOn(Schedulers.boundedElastic())
9290
.doOnSubscribe(s -> LOGGER.debug("[getToken] Getting vault client token"))
9391
.doOnSuccess(s -> LOGGER.debug("[getToken][success] result: {}", mask(s)))
9492
.doOnError(th -> LOGGER.error("[getToken][error] cause: {}", th.toString()));

vault/src/main/java/io/scalecube/security/vault/VaultServiceTokenSupplier.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,6 @@
1414
import org.slf4j.LoggerFactory;
1515
import reactor.core.Exceptions;
1616
import reactor.core.publisher.Mono;
17-
import reactor.core.scheduler.Schedulers;
1817

1918
public final class VaultServiceTokenSupplier {
2019

@@ -112,7 +111,6 @@ public Mono<String> getToken(Map<String, String> tags) {
112111
vaultToken -> {
113112
final String uri = buildServiceTokenUri(tags);
114113
return Mono.fromCallable(() -> rpcGetToken(uri, vaultToken))
115-
.subscribeOn(Schedulers.boundedElastic())
116114
.doOnSubscribe(
117115
s ->
118116
LOGGER.debug(

0 commit comments

Comments
 (0)