From 4555123b7d253baba730bcd0726f89561e6e8e11 Mon Sep 17 00:00:00 2001 From: Ferdinand Jacobs Date: Fri, 20 Dec 2019 21:20:08 +0100 Subject: [PATCH 1/2] Fix typo in RSocket docs See gh-19424 --- .../src/main/asciidoc/spring-boot-features.adoc | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 1890527f01..cb2c6e1ebf 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 @@ -3035,7 +3035,7 @@ The following code shows a typical example: } public Mono someRSocketCall(String name) { - return this.requester.route("user").data(name) + return this.rsocketRequester.route("user").data(name) .retrieveMono(User.class); } From 82391a406a6e5fb54fd6a2a3df6f7eb1053a6359 Mon Sep 17 00:00:00 2001 From: Brian Clozel Date: Fri, 20 Dec 2019 21:55:59 +0100 Subject: [PATCH 2/2] 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)); } }