root
/
spring-boot
mirror of https://github.com/spring-projects/spring-boot.git
1
0
Fork 0
Code Issues Actions 19 Packages Projects Releases Wiki Activity

Merge branch '2.2.x' 

Closes gh-19425
This commit is contained in:
Brian Clozel 2019-12-20 22:12:20 +01:00
parent 88d76a24d0 92aae91482
commit 813c901905
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -3027,16 +3027,16 @@ The following code shows a typical example:
@Service @Service
public class MyService { public class MyService {
private final RSocketRequester rsocketRequester; private final Mono<RSocketRequester> rsocketRequester;
public MyService(RSocketRequester.Builder rsocketRequesterBuilder) { public MyService(RSocketRequester.Builder rsocketRequesterBuilder) {
this.rsocketRequester = rsocketRequesterBuilder this.rsocketRequester = rsocketRequesterBuilder
.connectTcp("example.org", 9898).block(); .connectTcp("example.org", 9898).cache();
} }
public Mono<User> someRSocketCall(String name) { public Mono<User> someRSocketCall(String name) {
return this.requester.route("user").data(name) return this.rsocketRequester.flatMap(req ->
.retrieveMono(User.class); req.route("user").data(name).retrieveMono(User.class));
} }
} }