From 82391a406a6e5fb54fd6a2a3df6f7eb1053a6359 Mon Sep 17 00:00:00 2001 From: Brian Clozel Date: Fri, 20 Dec 2019 21:55:59 +0100 Subject: [PATCH] Polish See gh-19424 --- .../src/main/asciidoc/spring-boot-features.adoc | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) 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 cb2c6e1ebf..2c1aa575dd 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)); } }