public static interface RSocketRequester.RetrieveSpec
Modifier and Type | Method and Description |
---|---|
<T> reactor.core.publisher.Flux<T> |
retrieveFlux(Class<T> dataType)
Perform an
requestStream or a
requestChannel exchange depending on
whether the request input is single or multi-payload. |
<T> reactor.core.publisher.Flux<T> |
retrieveFlux(ParameterizedTypeReference<T> dataTypeRef)
Variant of
retrieveFlux(Class) for when the dataType has
to have a generic type. |
<T> reactor.core.publisher.Mono<T> |
retrieveMono(Class<T> dataType)
Perform a
requestResponse exchange. |
<T> reactor.core.publisher.Mono<T> |
retrieveMono(ParameterizedTypeReference<T> dataTypeRef)
Variant of
retrieveMono(Class) for when the dataType has
to have a generic type. |
reactor.core.publisher.Mono<Void> |
send()
Perform a
fireAndForget sending the
provided data and metadata. |
reactor.core.publisher.Mono<Void> send()
fireAndForget
sending the
provided data and metadata.<T> reactor.core.publisher.Mono<T> retrieveMono(Class<T> dataType)
requestResponse
exchange.
If the return type is Mono<Void>
, the Mono
will
complete after all data is consumed.
Note: This method will raise an error if
the request payload is a multivalued Publisher
as there is
no many-to-one RSocket interaction.
T
- parameter for the expected data typedataType
- the expected data type for the response<T> reactor.core.publisher.Mono<T> retrieveMono(ParameterizedTypeReference<T> dataTypeRef)
retrieveMono(Class)
for when the dataType has
to have a generic type. See ParameterizedTypeReference
.<T> reactor.core.publisher.Flux<T> retrieveFlux(Class<T> dataType)
requestStream
or a
requestChannel
exchange depending on
whether the request input is single or multi-payload.
If the return type is Flux<Void>
, the Flux
will
complete after all data is consumed.
T
- parameterize the expected type of valuesdataType
- the expected type for values in the response<T> reactor.core.publisher.Flux<T> retrieveFlux(ParameterizedTypeReference<T> dataTypeRef)
retrieveFlux(Class)
for when the dataType has
to have a generic type. See ParameterizedTypeReference
.