Polishing contribution

Closes gh-30403

Author: rstoyanchev

framework-docs/modules/ROOT/pages/integration/rest-clients.adoc

@@ -497,10 +497,12 @@ Annotated, HTTP exchange methods support the following return values:
 TIP: You can also use any other async or reactive types registered in the
 `ReactiveAdapterRegistry`.
 
-TIP: For non-reactive types, blocking from a reactive publisher is performed
-under the hood by the framework. By default, it is done without a timeout.
-You can set a timeout for blocking by calling `blockTimeout(Duration blockTimeout)`
-on `HttpServiceProxyFactory.Builder`.
+By default, the behavior of HTTP service methods with synchronous (blocking) method
+signature depends on connection and timeout settings of the underlying HTTP client.
+`HttpServiceProxyFactory.Builder` does expose a `blockTimeout` option that also lets you
+configure the maximum time to block for a response, but we recommend configuring timeout
+values directly on the underlying HTTP client, which likely provides more control over
+such settings.
 
 
 [[rest-http-interface-exceptions]]

framework-docs/modules/ROOT/pages/rsocket.adoc

@@ -1064,7 +1064,9 @@ Annotated, RSocket exchange methods support return values that are concrete valu
 any producer of value(s) that can be adapted to a Reactive Streams `Publisher` via
 `ReactiveAdapterRegistry`.
 
-TIP: For non-reactive types, blocking from a reactive publisher is performed
-under the hood by the framework. By default, it is done without a timeout.
-You can set a timeout for blocking by calling `blockTimeout(Duration blockTimeout)`
-on `RSocketServiceProxyFactory.Builder`.
+By default, the behavior of RSocket service methods with synchronous (blocking) method
+signature depends on response timeout settings of the underlying RSocket `ClientTransport`
+as well as RSocket keep-alive settings. `RSocketServiceProxyFactory.Builder` does expose a
+`blockTimeout` option that also lets you configure the maximum time to block for a response,
+but we recommend configuring timeout values at the RSocket level for more control.
+

spring-messaging/src/main/java/org/springframework/messaging/rsocket/service/RSocketServiceMethod.java

@@ -73,8 +73,7 @@ final class RSocketServiceMethod {
 		this.parameters = initMethodParameters(method);
 		this.argumentResolvers = argumentResolvers;
 		this.route = initRoute(method, containingClass, rsocketRequester.strategies(), embeddedValueResolver);
-		this.responseFunction = initResponseFunction(
-				rsocketRequester, method, reactiveRegistry, blockTimeout);
+		this.responseFunction = initResponseFunction(rsocketRequester, method, reactiveRegistry, blockTimeout);
 	}
 
 	private static MethodParameter[] initMethodParameters(Method method) {
@@ -163,11 +162,16 @@ else if (reactiveAdapter == null) {
 			if (reactiveAdapter != null) {
 				return reactiveAdapter.fromPublisher(responsePublisher);
 			}
-			return (blockForOptional ?
-					(blockTimeout != null ? ((Mono<?>) responsePublisher).blockOptional(blockTimeout) :
-							((Mono<?>) responsePublisher).blockOptional()) :
-					(blockTimeout != null ? ((Mono<?>) responsePublisher).block(blockTimeout) :
-							((Mono<?>) responsePublisher).block()));
+			if (blockForOptional) {
+				return (blockTimeout != null ?
+						((Mono<?>) responsePublisher).blockOptional(blockTimeout) :
+						((Mono<?>) responsePublisher).blockOptional());
+			}
+			else {
+				return (blockTimeout != null ?
+						((Mono<?>) responsePublisher).block(blockTimeout) :
+						((Mono<?>) responsePublisher).block());
+			}
 		});
 	}
 

spring-messaging/src/main/java/org/springframework/messaging/rsocket/service/RSocketServiceProxyFactory.java

@@ -188,14 +188,17 @@ public Builder reactiveAdapterRegistry(ReactiveAdapterRegistry registry) {
 		}
 
 		/**
-		 * Configure how long to wait for a response for an HTTP service method
+		 * Configure how long to block for the response of an RSocket service method
 		 * with a synchronous (blocking) method signature.
-		 * <p>By default this is {@code null},
-		 * in which case means blocking on publishers is done without a timeout.
+		 * <p>By default this is not set, in which case the behavior depends on
+		 * connection and response timeout settings of the underlying RSocket
+		 * {@code ClientTransport} as well as RSocket keep-alive settings.
+		 * We recommend configuring timeout values at the RSocket level which
+		 * provides more control.
 		 * @param blockTimeout the timeout value
 		 * @return this same builder instance
 		 */
-		public Builder blockTimeout(Duration blockTimeout) {
+		public Builder blockTimeout(@Nullable Duration blockTimeout) {
 			this.blockTimeout = blockTimeout;
 			return this;
 		}
@@ -208,8 +211,7 @@ public RSocketServiceProxyFactory build() {
 
 			return new RSocketServiceProxyFactory(
 					this.rsocketRequester, initArgumentResolvers(),
-					this.embeddedValueResolver, this.reactiveAdapterRegistry,
-					this.blockTimeout);
+					this.embeddedValueResolver, this.reactiveAdapterRegistry, this.blockTimeout);
 		}
 
 		private List<RSocketServiceArgumentResolver> initArgumentResolvers() {

spring-web/src/main/java/org/springframework/web/service/invoker/HttpServiceMethod.java

@@ -123,15 +123,13 @@ private void applyArguments(HttpRequestValues.Builder requestValues, Object[] ar
 				}
 			}
 			int index = i;
-			Assert.state(resolved, () -> formatArgumentError(this.parameters[index], "No suitable resolver"));
+			Assert.state(resolved, () ->
+					"Could not resolve parameter [" + this.parameters[index].getParameterIndex() + "] in " +
+							this.parameters[index].getExecutable().toGenericString() +
+							(StringUtils.hasText("No suitable resolver") ? ": " + "No suitable resolver" : ""));
 		}
 	}
 
-	private static String formatArgumentError(MethodParameter param, String message) {
-		return "Could not resolve parameter [" + param.getParameterIndex() + "] in " +
-				param.getExecutable().toGenericString() + (StringUtils.hasText(message) ? ": " + message : "");
-	}
-
 
 	/**
 	 * Factory for {@link HttpRequestValues} with values extracted from the type
@@ -277,17 +275,6 @@ private record ResponseFunction(
 			@Nullable ReactiveAdapter returnTypeAdapter,
 			boolean blockForOptional, @Nullable Duration blockTimeout) {
 
-		private ResponseFunction(
-				Function<HttpRequestValues, Publisher<?>> responseFunction,
-				@Nullable ReactiveAdapter returnTypeAdapter,
-				boolean blockForOptional, Duration blockTimeout) {
-
-			this.responseFunction = responseFunction;
-			this.returnTypeAdapter = returnTypeAdapter;
-			this.blockForOptional = blockForOptional;
-			this.blockTimeout = blockTimeout;
-		}
-
 		@Nullable
 		public Object execute(HttpRequestValues requestValues) {
 
@@ -297,11 +284,16 @@ public Object execute(HttpRequestValues requestValues) {
 				return this.returnTypeAdapter.fromPublisher(responsePublisher);
 			}
 
-			return (this.blockForOptional ?
-					(this.blockTimeout != null ? ((Mono<?>) responsePublisher).blockOptional(this.blockTimeout) :
-							((Mono<?>) responsePublisher).blockOptional()) :
-					(this.blockTimeout != null ? ((Mono<?>) responsePublisher).block(this.blockTimeout) :
-							((Mono<?>) responsePublisher).block()));
+			if (this.blockForOptional) {
+				return (this.blockTimeout != null ?
+						((Mono<?>) responsePublisher).blockOptional(this.blockTimeout) :
+						((Mono<?>) responsePublisher).blockOptional());
+			}
+			else {
+				return (this.blockTimeout != null ?
+						((Mono<?>) responsePublisher).block(this.blockTimeout) :
+						((Mono<?>) responsePublisher).block());
+			}
 		}
 
 
@@ -310,7 +302,7 @@ public Object execute(HttpRequestValues requestValues) {
 		 */
 		public static ResponseFunction create(
 				HttpClientAdapter client, Method method, ReactiveAdapterRegistry reactiveRegistry,
-				Duration blockTimeout) {
+				@Nullable Duration blockTimeout) {
 
 			MethodParameter returnParam = new MethodParameter(method, -1);
 			Class<?> returnType = returnParam.getParameterType();

spring-web/src/main/java/org/springframework/web/service/invoker/HttpServiceProxyFactory.java

@@ -207,14 +207,16 @@ public Builder reactiveAdapterRegistry(ReactiveAdapterRegistry registry) {
 		}
 
 		/**
-		 * Configure how long to wait for a response for an HTTP service method
+		 * Configure how long to block for the response of an HTTP service method
 		 * with a synchronous (blocking) method signature.
-		 * <p>By default this is {@code null},
-		 * in which case means blocking on publishers is done without a timeout.
+		 * <p>By default this is not set, in which case the behavior depends on
+		 * connection and request timeout settings of the underlying HTTP client.
+		 * We recommend configuring timeout values directly on the underlying HTTP
+		 * client, which provides more control over such settings.
 		 * @param blockTimeout the timeout value
 		 * @return this same builder instance
 		 */
-		public Builder blockTimeout(Duration blockTimeout) {
+		public Builder blockTimeout(@Nullable Duration blockTimeout) {
 			this.blockTimeout = blockTimeout;
 			return this;
 		}
@@ -227,8 +229,7 @@ public HttpServiceProxyFactory build() {
 
 			return new HttpServiceProxyFactory(
 					this.clientAdapter, initArgumentResolvers(),
-					this.embeddedValueResolver, this.reactiveAdapterRegistry,
-					this.blockTimeout);
+					this.embeddedValueResolver, this.reactiveAdapterRegistry, this.blockTimeout);
 		}
 
 		private List<HttpServiceArgumentResolver> initArgumentResolvers() {