From f3850b7520cd579cca2316c281dbd6884f4348a5 Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Fri, 27 Sep 2019 11:30:28 -0400 Subject: [PATCH] RSocket Doc Polishing --- src/reference/asciidoc/rsocket.adoc | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/reference/asciidoc/rsocket.adoc b/src/reference/asciidoc/rsocket.adoc index 66ece006fb..daf161ad77 100644 --- a/src/reference/asciidoc/rsocket.adoc +++ b/src/reference/asciidoc/rsocket.adoc @@ -156,12 +156,12 @@ Such an expression must evaluate to a `Map`. When `command` is not `fireAndForget`, an `expectedResponseType` must be supplied. It is a `String.class` by default. An expression for this option can evaluate to a `ParameterizedTypeReference`. -See `RSocketRequester.RequestSpec.retrieveMono()` and `RSocketRequester.RequestSpec.retrieveFlux()` JavaDocs for more information about reply data and its type. +See the `RSocketRequester.RequestSpec.retrieveMono()` and `RSocketRequester.RequestSpec.retrieveFlux()` JavaDocs for more information about reply data and its type. A reply `payload` from the `RSocketOutboundGateway` is always `Mono` (even for a `fireAndForget` command it is `Mono`) always making this component as `async`. Such a `Mono` is subscribed before producing into the `outputChannel` for regular channels or processed on demand by the `FluxMessageChannel`. -A `Flux` response for the `requestStreamOrChannel` command is also wrapped into a mentioned reply `Mono`. -It can be flatten downstream by the `FluxMessageChannel` with a passthrough service activator: +A `Flux` response for the `requestStreamOrChannel` command is also wrapped into a reply `Mono`. +It can be flattened downstream by the `FluxMessageChannel` with a passthrough service activator: ==== [source, java]