Top Description Fields Constructors Methods

org.springframework.messaging.rsocket.service

pack-priv final Class RSocketServiceMethod

Class Inheritance

extends Object

java.lang.Object
org.springframework.messaging.rsocket.service.RSocketServiceMethod

Imports

java.lang.reflect.Method, java.time.Duration, java.util.Iterator, .List, .Map, .Optional, java.util.function.Function, org.reactivestreams.Publisher, reactor.core.publisher.Mono, org.springframework.core.DefaultParameterNameDiscoverer, .MethodParameter, .ParameterizedTypeReference, .ReactiveAdapter, .ReactiveAdapterRegistry, org.springframework.core.annotation.AnnotatedElementUtils, .SynthesizingMethodParameter, org.springframework.lang.Nullable, org.springframework.messaging.rsocket.RSocketRequester, .RSocketStrategies, org.springframework.util.Assert, .ClassUtils, .MimeType, .StringUtils, .StringValueResolver

Implements the invocation of an @RSocketExchange-annotated, RSocket service proxy method by delegating to an RSocketRequester to perform actual requests.

Author: Rossen Stoyanchev
Since: 6.0

Field Summary

Modifier and Type	Field and Description
private final List<RSocketServiceArgumentResolver>	argumentResolvers
private final Method	method
private final MethodParameter[]	parameters
private final Function<RSocketRequestValues, Object>	responseFunction
private final String	route

Constructor Summary

Access	Constructor and Description
pack-priv	RSocketServiceMethod(Method method, Class<?> containingClass, List<RSocketServiceArgumentResolver> argumentResolvers, RSocketRequester rsocketRequester, StringValueResolver embeddedValueResolver, ReactiveAdapterRegistry reactiveRegistry, Duration blockTimeout)

Method Summary

Modifier and Type	Method and Description
private void	applyArguments(RSocketRequestValues.Builder requestValues, Object[] arguments)
private static String	formatArgumentError(MethodParameter param, String message)
public Method	getMethod()
private static MethodParameter[]	initMethodParameters(Method method)
private static RSocketRequester.RetrieveSpec	initRequest(RSocketRequester requester, RSocketRequestValues requestValues)
private static Function<RSocketRequestValues, Object>	initResponseFunction(RSocketRequester requester, Method method, ReactiveAdapterRegistry reactiveRegistry, Duration blockTimeout)
private static String	initRoute(Method method, Class<?> containingClass, RSocketStrategies strategies, StringValueResolver embeddedValueResolver)
public Object	invoke(Object[] arguments)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

argumentResolvers	back to summary
private final List<RSocketServiceArgumentResolver> argumentResolvers

method	back to summary
private final Method method

parameters	back to summary
private final MethodParameter[] parameters

responseFunction	back to summary
private final Function<RSocketRequestValues, Object> responseFunction

route	back to summary
private final String route Annotations @Nullable

Constructor Detail

RSocketServiceMethod	back to summary
pack-priv RSocketServiceMethod(Method method, Class<?> containingClass, List<RSocketServiceArgumentResolver> argumentResolvers, RSocketRequester rsocketRequester, StringValueResolver embeddedValueResolver, ReactiveAdapterRegistry reactiveRegistry, Duration blockTimeout)

Method Detail

applyArguments	back to summary
private void applyArguments(RSocketRequestValues.Builder requestValues, Object[] arguments)

formatArgumentError	back to summary
private static String formatArgumentError(MethodParameter param, String message) Annotations @SuppressWarnings:SameParameterValue

getMethod	back to summary
public Method getMethod()

initMethodParameters	back to summary
private static MethodParameter[] initMethodParameters(Method method)

initRequest	back to summary
private static RSocketRequester.RetrieveSpec initRequest(RSocketRequester requester, RSocketRequestValues requestValues) Annotations @SuppressWarnings:ReactiveStreamsUnusedPublisher

initResponseFunction	back to summary
private static Function<RSocketRequestValues, Object> initResponseFunction(RSocketRequester requester, Method method, ReactiveAdapterRegistry reactiveRegistry, Duration blockTimeout)

initRoute	back to summary
private static String initRoute(Method method, Class<?> containingClass, RSocketStrategies strategies, StringValueResolver embeddedValueResolver) Annotations @Nullable

invoke	back to summary
public Object invoke(Object[] arguments) Annotations @Nullable