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 14f15e12dfb0d85298dce21c632dca846191f3f0..4d6d7a40ef312dc1f78f5c74721055e7b164f577 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);
 	}