Polish

spring-webflux/src/main/java/org/springframework/web/reactive/BindingContext.java

@@ -24,7 +24,8 @@ import org.springframework.web.bind.support.WebExchangeDataBinder;
 import org.springframework.web.server.ServerWebExchange;
 
 /**
- * Context to assist with processing a request and binding it onto Objects.
+ * Context to assist with binding request data onto Objects and provide access
+ * to a shared {@link Model} with controller-specific attributes.
  *
  * <p>Provides  methods to create a {@link WebExchangeDataBinder} for a specific
  * target, command Object to apply data binding and validation to, or without a

spring-webflux/src/main/java/org/springframework/web/reactive/result/method/annotation/ModelInitializer.java

@@ -30,6 +30,7 @@ import org.springframework.core.ReactiveAdapter;
 import org.springframework.core.ReactiveAdapterRegistry;
 import org.springframework.core.ResolvableType;
 import org.springframework.core.annotation.AnnotatedElementUtils;
+import org.springframework.lang.Nullable;
 import org.springframework.util.StringUtils;
 import org.springframework.web.bind.annotation.ModelAttribute;
 import org.springframework.web.reactive.BindingContext;
@@ -73,12 +74,13 @@ class ModelInitializer {
 		List<Mono<HandlerResult>> resultList = new ArrayList<>();
 		attributeMethods.forEach(invocable -> resultList.add(invocable.invoke(exchange, bindingContext)));
 
-		return Mono.zip(resultList, objectArray -> {
-			return Arrays.stream(objectArray)
-					.map(object -> (HandlerResult) object)
-					.map(handlerResult -> handleResult(handlerResult, bindingContext))
-					.collect(Collectors.toList());
-		}).flatMap(completionList -> Mono.when(completionList));
+		return Mono
+				.zip(resultList, objectArray -> {
+					return Arrays.stream(objectArray)
+							.map(object -> handleResult(((HandlerResult) object), bindingContext))
+							.collect(Collectors.toList());
+				})
+				.flatMap(completionList -> Mono.when(completionList));
 	}
 
 	private Mono<Void> handleResult(HandlerResult handlerResult, BindingContext bindingContext) {
@@ -86,11 +88,8 @@ class ModelInitializer {
 		if (value != null) {
 			ResolvableType type = handlerResult.getReturnType();
 			ReactiveAdapter adapter = this.adapterRegistry.getAdapter(type.getRawClass(), value);
-			if (adapter != null) {
-				Class<?> attributeType = (adapter.isNoValue() ? Void.class : type.resolveGeneric());
-				if (attributeType == Void.class) {
-					return Mono.from(adapter.toPublisher(value));
-				}
+			if (isAsyncVoidType(type, adapter)) {
+				return Mono.from(adapter.toPublisher(value));
 			}
 			String name = getAttributeName(handlerResult.getReturnTypeSource());
 			bindingContext.getModel().asMap().putIfAbsent(name, value);
@@ -98,6 +97,10 @@ class ModelInitializer {
 		return Mono.empty();
 	}
 
+	private boolean isAsyncVoidType(ResolvableType type, @Nullable  ReactiveAdapter adapter) {
+		return adapter != null && (adapter.isNoValue() || type.resolveGeneric() == Void.class);
+	}
+
 	private String getAttributeName(MethodParameter param) {
 		return Optional
 				.ofNullable(AnnotatedElementUtils.findMergedAnnotation(param.getAnnotatedElement(), ModelAttribute.class))

spring-webflux/src/main/java/org/springframework/web/reactive/result/view/AbstractView.java

@@ -147,7 +147,6 @@ public abstract class AbstractView implements View, ApplicationContextAware {
 	 * Obtain the ApplicationContext for actual use.
 	 * @return the ApplicationContext (never {@code null})
 	 * @throws IllegalStateException in case of no ApplicationContext set
-	 * @since 5.0
 	 */
 	protected final ApplicationContext obtainApplicationContext() {
 		ApplicationContext applicationContext = getApplicationContext();
@@ -191,7 +190,9 @@ public abstract class AbstractView implements View, ApplicationContextAware {
 	 * <p>The default implementation creates a combined output Map that includes
 	 * model as well as static attributes with the former taking precedence.
 	 */
-	protected Mono<Map<String, Object>> getModelAttributes(@Nullable Map<String, ?> model, ServerWebExchange exchange) {
+	protected Mono<Map<String, Object>> getModelAttributes(@Nullable Map<String, ?> model,
+			ServerWebExchange exchange) {
+
 		int size = (model != null ? model.size() : 0);
 
 		Map<String, Object> attributes = new LinkedHashMap<>(size);
@@ -203,9 +204,11 @@ public abstract class AbstractView implements View, ApplicationContextAware {
 	}
 
 	/**
-	 * By default, resolve async attributes supported by the {@link ReactiveAdapterRegistry} to their blocking counterparts.
-	 * <p>View implementations capable of taking advantage of reactive types can override this method if needed.
-	 * @return {@code Mono} to represent when the async attributes have been resolved
+	 * By default, resolve async attributes supported by the
+	 * {@link ReactiveAdapterRegistry} to their blocking counterparts.
+	 * <p>View implementations capable of taking advantage of reactive types
+	 * can override this method if needed.
+	 * @return {@code Mono} for the completion of async attributes resolution
 	 */
 	protected Mono<Void> resolveAsyncAttributes(Map<String, Object> model) {
 
@@ -252,8 +255,9 @@ public abstract class AbstractView implements View, ApplicationContextAware {
 
 	/**
 	 * Create a RequestContext to expose under the specified attribute name.
-	 * <p>The default implementation creates a standard RequestContext instance for the
-	 * given request and model. Can be overridden in subclasses for custom instances.
+	 * <p>The default implementation creates a standard RequestContext instance
+	 * for the given request and model. Can be overridden in subclasses for
+	 * custom instances.
 	 * @param exchange current exchange
 	 * @param model combined output Map (never {@code null}),
 	 * with dynamic values taking precedence over static attributes
@@ -269,7 +273,8 @@ public abstract class AbstractView implements View, ApplicationContextAware {
 	 * <p>The default implementation looks in the {@link #getApplicationContext()
 	 * Spring configuration} for a {@code RequestDataValueProcessor} bean with
 	 * the name {@link #REQUEST_DATA_VALUE_PROCESSOR_BEAN_NAME}.
-	 * @return the RequestDataValueProcessor, or null if there is none at the application context.
+	 * @return the RequestDataValueProcessor, or null if there is none at the
+	 * application context.
 	 */
 	@Nullable
 	protected RequestDataValueProcessor getRequestDataValueProcessor() {
@@ -286,7 +291,8 @@ public abstract class AbstractView implements View, ApplicationContextAware {
 	 * with dynamic values taking precedence over static attributes
 	 * @param contentType the content type selected to render with which should
 	 * match one of the {@link #getSupportedMediaTypes() supported media types}.
-	 *@param exchange current exchange  @return {@code Mono} to represent when and if rendering succeeds
+	 *@param exchange current exchange  @return {@code Mono} to represent when
+	 * and if rendering succeeds
 	 */
 	protected abstract Mono<Void> renderInternal(Map<String, Object> renderAttributes,
 			@Nullable MediaType contentType, ServerWebExchange exchange);