From 9766ce5e1ab8f7148eee01b3d0fce543af30dc25 Mon Sep 17 00:00:00 2001
From: Jan Zickermann <jan.zickermann@dataport.de>
Date: Thu, 29 Aug 2024 16:23:50 +0200
Subject: [PATCH] OZG-6344 Use expected pipe behavior

---
 .../DFoerdermittelEngineBasedSemantikAdapter.java          | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/semantik-adapter/src/main/java/de/ozgcloud/eingang/semantik/enginebased/dfoerdermittel/DFoerdermittelEngineBasedSemantikAdapter.java b/semantik-adapter/src/main/java/de/ozgcloud/eingang/semantik/enginebased/dfoerdermittel/DFoerdermittelEngineBasedSemantikAdapter.java
index 14f15e12d..4d6d7a40e 100644
--- a/semantik-adapter/src/main/java/de/ozgcloud/eingang/semantik/enginebased/dfoerdermittel/DFoerdermittelEngineBasedSemantikAdapter.java
+++ b/semantik-adapter/src/main/java/de/ozgcloud/eingang/semantik/enginebased/dfoerdermittel/DFoerdermittelEngineBasedSemantikAdapter.java
@@ -56,7 +56,6 @@ public class DFoerdermittelEngineBasedSemantikAdapter implements EngineBasedSema
 
 	FormData processFachnachricht(FormData formData) {
 		return pipe(
-				formData,
 				Stream.of(
 						this::addFormName,
 						this::addFormEngineName,
@@ -64,11 +63,11 @@ public class DFoerdermittelEngineBasedSemantikAdapter implements EngineBasedSema
 						this::addOrganisationsEinheitId,
 						this::addFormId
 				)
-		);
+		).apply(formData);
 	}
 
-	private FormData pipe(FormData formData, Stream<UnaryOperator<FormData>> functions) {
-		return functions
+	private UnaryOperator<FormData> pipe(Stream<UnaryOperator<FormData>> functions) {
+		return (formData) -> functions
 				.reduce(formData, (acc, f) -> f.apply(acc), (a, b) -> a);
 	}
 
-- 
GitLab