Interface RsocketRequester.Requestspec

All superinterfaces:

RsocketRequester.Metadataspec<RsocketRequester.Requestspec>, RsocketRequester.Retrievespec

Enclosing interface:

RsocketRequester

public static interface RsocketRequester.Requestspec
extends RsocketRequester.Metadataspec<RsocketRequester.Requestspec>, RsocketRequester.Retrievespec

spec to declare the input for an Rsocket request.

since:

5.2

Author:

Rossen stoyanchev, Brian Clozel

Method summary

Modifier and Type	Method	Description
RsocketRequester.Retrievespec	data(Object data)	Provide payload data for the request.
RsocketRequester.Retrievespec	data(Object&nbsp;producer, Class<?>&nbsp;elementClass)	Variant of data(Object) that also accepts a hint for the types of values that will be produced.
RsocketRequester.Retrievespec	data(Object&nbsp;producer, ParameterizedTypeReference<?>&nbsp;elementTypeRef)	Variant of data(Object, Class) for when the type hint has to have a generic type.
RsocketRequester.Requestspec	metadata(Consumer<RsocketRequester.Metadataspec<?>>&nbsp;configurer)	Append additional metadata entries through a Consumer.
reactor.core.publisher.Mono<Void>	sendMetadata()	Perform a metadataPush.

Methods inherited from interface RsocketRequester.Metadataspec

metadata

Methods inherited from interface RsocketRequester.Retrievespec

retrieveFlux, retrieveFlux, retrieveMono, retrieveMono, send

Method Details

metadata

RsocketRequester.Requestspec&nbsp;metadata(Consumer<RsocketRequester.Metadataspec<?>>&nbsp;configurer)

Append additional metadata entries through a Consumer. This enables libraries such as spring security to provide shortcuts for applying a set of customizations.

Parameters:

configurer - the configurer to apply

Throws:

IllegalArgumentException - if not using composite metadata.

sendMetadata

reactor.core.publisher.Mono<Void>&nbsp;sendMetadata()

Perform a metadataPush.

since:

5.3

data

RsocketRequester.Retrievespec data(Object data)

Provide payload data for the request. This can be one of:

• Concrete value
• Publisher of value(s)
• Any other producer of value(s) that can be adapted to a Publisher via ReactiveAdapterRegistry

Parameters:

data - the Object value for the payload data

Returns:

spec to declare the expected response

data

RsocketRequester.Retrievespec data(Object producer,
 Class<?>&nbsp;elementClass)

Variant of 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.

Parameters:

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 produced

Returns:

spec to declare the expected response

data

RsocketRequester.Retrievespec data(Object producer,
 ParameterizedTypeReference<?>&nbsp;elementTypeRef)

Variant of data(Object, Class) for when the type hint has to have a generic type. see ParameterizedTypeReference.

Parameters:

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

Returns:

spec to declare the expected response