Skip to content

Commit aedf900

Browse files
committed
Merge branch '1068-protect-blocking-api' into 3.x
[p]resolves #1068]
2 parents 4852d52 + 529cc79 commit aedf900

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

cloudfoundry-client-reactor/src/main/java/org/cloudfoundry/reactor/uaa/UsernameProvider.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,8 +49,8 @@ final class UsernameProvider {
4949

5050
Mono<String> get() {
5151
return getToken(this.connectionContext, this.tokenProvider)
52+
.publishOn(Schedulers.elastic())
5253
.map(this::getUsername)
53-
.subscribeOn(Schedulers.elastic())
5454
.retry(1, t -> {
5555
if (t instanceof ExpiredJwtException) {
5656
this.tokenProvider.invalidate(this.connectionContext);

0 commit comments

Comments
 (0)