Skip to content

Commit 92aae91

Browse files
committed
Merge pull request #19424 from fjacobs
* pr/19424: Polish Fix typo in RSocket docs Closes gh-19424
2 parents ea00ab9 + 82391a4 commit 92aae91

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

spring-boot-project/spring-boot-docs/src/main/asciidoc/spring-boot-features.adoc

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -3027,16 +3027,16 @@ The following code shows a typical example:
30273027
@Service
30283028
public class MyService {
30293029
3030-
private final RSocketRequester rsocketRequester;
3030+
private final Mono<RSocketRequester> rsocketRequester;
30313031
30323032
public MyService(RSocketRequester.Builder rsocketRequesterBuilder) {
30333033
this.rsocketRequester = rsocketRequesterBuilder
3034-
.connectTcp("example.org", 9898).block();
3034+
.connectTcp("example.org", 9898).cache();
30353035
}
30363036
30373037
public Mono<User> someRSocketCall(String name) {
3038-
return this.requester.route("user").data(name)
3039-
.retrieveMono(User.class);
3038+
return this.rsocketRequester.flatMap(req ->
3039+
req.route("user").data(name).retrieveMono(User.class));
30403040
}
30413041
30423042
}

0 commit comments

Comments
 (0)