Commit 82391a40 authored by Brian Clozel's avatar Brian Clozel

Polish

See gh-19424
parent 4555123b
...@@ -3027,16 +3027,16 @@ The following code shows a typical example: ...@@ -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.rsocketRequester.route("user").data(name) return this.rsocketRequester.flatMap(req ->
.retrieveMono(User.class); req.route("user").data(name).retrieveMono(User.class));
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment