public static interface RSocketRequester.RequestSpec extends RSocketRequester.MetadataSpec<RSocketRequester.RequestSpec>, RSocketRequester.RetrieveSpec
Modifier and Type | Method and Description |
---|---|
RSocketRequester.RetrieveSpec |
data(Object data)
Provide payload data for the request.
|
RSocketRequester.RetrieveSpec |
data(Object producer,
Class<?> elementClass)
Variant of
data(Object) that also accepts a hint for the
types of values that will be produced. |
RSocketRequester.RetrieveSpec |
data(Object producer,
ParameterizedTypeReference<?> elementTypeRef)
Variant of
data(Object, Class) for when the type hint has
to have a generic type. |
RSocketRequester.RequestSpec |
metadata(Consumer<RSocketRequester.MetadataSpec<?>> configurer)
Append additional metadata entries through a
Consumer . |
reactor.core.publisher.Mono<Void> |
sendMetadata()
Perform a
metadataPush . |
metadata
retrieveFlux, retrieveFlux, retrieveMono, retrieveMono, send
RSocketRequester.RequestSpec metadata(Consumer<RSocketRequester.MetadataSpec<?>> configurer)
Consumer
.
This enables libraries such as Spring Security to provide shortcuts
for applying a set of customizations.configurer
- the configurer to applyIllegalArgumentException
- if not using composite metadata.reactor.core.publisher.Mono<Void> sendMetadata()
metadataPush
.RSocketRequester.RetrieveSpec data(Object data)
Publisher
of value(s)
Publisher
via ReactiveAdapterRegistry
data
- the Object value for the payload dataRSocketRequester.RetrieveSpec data(Object producer, Class<?> elementClass)
data(Object)
that also accepts a hint for the
types of values that will be produced. The class hint is used to
find a compatible Encoder
once, up front vs per value.producer
- the source of payload data value(s). This must be a
Publisher
or another producer adaptable to a
Publisher
via ReactiveAdapterRegistry
elementClass
- the type of values to be producedRSocketRequester.RetrieveSpec data(Object producer, ParameterizedTypeReference<?> elementTypeRef)
data(Object, Class)
for when the type hint has
to have a generic type. See ParameterizedTypeReference
.producer
- the source of payload data value(s). This must be a
Publisher
or another producer adaptable to a
Publisher
via ReactiveAdapterRegistry
elementTypeRef
- the type of values to be produced