public static interface RSocketRequester.ResponseSpec
| Modifier and Type | Method and Description |
|---|---|
<T> reactor.core.publisher.Flux<T> |
retrieveFlux(Class<T> dataType)
Perform
requestStream or
requestChannel depending on whether
the request input consists of a single or multiple payloads. |
<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
requestResponse. |
<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
fireAndForget. |
reactor.core.publisher.Mono<Void> send()
fireAndForget.<T> reactor.core.publisher.Mono<T> retrieveMono(Class<T> dataType)
requestResponse. If the
expected data type is Void.class, the returned Mono
will complete after all data is consumed.
Note: Use of this method will raise an error if
the request payload is a multivalued Publisher as
determined through the configured ReactiveAdapterRegistry.
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
requestChannel depending on whether
the request input consists of a single or multiple payloads.
If the expected data type is Void.class, the returned
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.