From 066f3d1c48261b93f0aad969cfe40d4b937af0f2 Mon Sep 17 00:00:00 2001
From: Oleg Zhurakousky <ozhurakousky@vmware.com>
Date: Thu, 9 May 2024 16:39:01 +0200
Subject: [PATCH] GH-1145 Fix List conversion for Function<Message<List>, ..>

Resolves #1145
---
 .../function/context/catalog/SimpleFunctionRegistry.java    | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/SimpleFunctionRegistry.java b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/SimpleFunctionRegistry.java
index 3c76d0bcf..eb315cf4f 100644
--- a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/SimpleFunctionRegistry.java
+++ b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/SimpleFunctionRegistry.java
@@ -1343,6 +1343,12 @@ public class SimpleFunctionRegistry implements FunctionRegistry {
 				if (collectionType == itemType) {
 					return message.getPayload();
 				}
+
+				if (collectionType != null
+						&& FunctionTypeUtils.getRawType(itemType).isAssignableFrom(collectionType.getClass())
+						&& FunctionTypeUtils.isMessage(type)) {
+					return message;
+				}
 			}
 
 			Object convertedInput = message.getPayload();