diff --git a/spring-boot-project/spring-boot-docs/src/main/asciidoc/spring-boot-features.adoc b/spring-boot-project/spring-boot-docs/src/main/asciidoc/spring-boot-features.adoc index cb2c6e1ebfd..2c1aa575ddc 100644 --- a/spring-boot-project/spring-boot-docs/src/main/asciidoc/spring-boot-features.adoc +++ b/spring-boot-project/spring-boot-docs/src/main/asciidoc/spring-boot-features.adoc @@ -3027,16 +3027,16 @@ The following code shows a typical example: @Service public class MyService { - private final RSocketRequester rsocketRequester; + private final Mono rsocketRequester; public MyService(RSocketRequester.Builder rsocketRequesterBuilder) { this.rsocketRequester = rsocketRequesterBuilder - .connectTcp("example.org", 9898).block(); + .connectTcp("example.org", 9898).cache(); } public Mono someRSocketCall(String name) { - return this.rsocketRequester.route("user").data(name) - .retrieveMono(User.class); + return this.rsocketRequester.flatMap(req -> + req.route("user").data(name).retrieveMono(User.class)); } }