Re-enable ignored tests

2020-05-04 20:44:10 +02:00
parent 74e10c106b
commit 8503c39104
6 changed files with 15 additions and 12 deletions
--- a/spring-cloud-function-web/src/main/java/org/springframework/cloud/function/web/RequestProcessor.java
+++ b/spring-cloud-function-web/src/main/java/org/springframework/cloud/function/web/RequestProcessor.java
@@ -200,7 +200,10 @@ public class RequestProcessor {
 		}

 		if (result instanceof Flux) {
-			result = Flux.from(result).collectList();
+			result = Flux.from(result).onErrorContinue((e, v) -> {
+				logger.error("Failed to process value: " + v, e);
+			})
+			.collectList();
 		}
 		return Mono.from(result).flatMap(body -> Mono.just(builder.body(body)));
 	}