You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: src/reference/asciidoc/rsocket.adoc
+3-3
Original file line number
Diff line number
Diff line change
@@ -156,12 +156,12 @@ Such an expression must evaluate to a `Map<Object, MimeType>`.
156
156
When `command` is not `fireAndForget`, an `expectedResponseType` must be supplied.
157
157
It is a `String.class` by default.
158
158
An expression for this option can evaluate to a `ParameterizedTypeReference`.
159
-
See `RSocketRequester.RequestSpec.retrieveMono()` and `RSocketRequester.RequestSpec.retrieveFlux()` JavaDocs for more information about reply data and its type.
159
+
See the `RSocketRequester.RequestSpec.retrieveMono()` and `RSocketRequester.RequestSpec.retrieveFlux()` JavaDocs for more information about reply data and its type.
160
160
161
161
A reply `payload` from the `RSocketOutboundGateway` is always `Mono` (even for a `fireAndForget` command it is `Mono<Void>`) always making this component as `async`.
162
162
Such a `Mono` is subscribed before producing into the `outputChannel` for regular channels or processed on demand by the `FluxMessageChannel`.
163
-
A `Flux` response for the `requestStreamOrChannel` command is also wrapped into a mentioned reply `Mono`.
164
-
It can be flatten downstream by the `FluxMessageChannel` with a passthrough service activator:
163
+
A `Flux` response for the `requestStreamOrChannel` command is also wrapped into a reply `Mono`.
164
+
It can be flattened downstream by the `FluxMessageChannel` with a passthrough service activator:
0 commit comments