diff --git a/vorgang-manager-server/src/main/java/de/ozgcloud/vorgang/vorgang/redirect/EingangForwarder.java b/vorgang-manager-server/src/main/java/de/ozgcloud/vorgang/vorgang/redirect/EingangForwarder.java
index 655df82a57fc19212085ed5c8e4e7747c39716af..1e12a3b6c91fae8df146896fd5b4d355f4ab5023 100644
--- a/vorgang-manager-server/src/main/java/de/ozgcloud/vorgang/vorgang/redirect/EingangForwarder.java
+++ b/vorgang-manager-server/src/main/java/de/ozgcloud/vorgang/vorgang/redirect/EingangForwarder.java
@@ -83,6 +83,7 @@ class EingangForwarder {
 		sendRouteForwarding(grpcRouteForwarding);
 		sendAttachments(attachments);
 		sendRepresentations(representations);
+		requestObserver.onCompleted();
 		waitForCompletion(future);
 	}
 
diff --git a/vorgang-manager-server/src/test/java/de/ozgcloud/vorgang/vorgang/redirect/EingangForwarderTest.java b/vorgang-manager-server/src/test/java/de/ozgcloud/vorgang/vorgang/redirect/EingangForwarderTest.java
index 3c58b837e5264cda3044a698ae40fed4269c102f..49798fe14b7f7f464616e5931d222ca970c07df5 100644
--- a/vorgang-manager-server/src/test/java/de/ozgcloud/vorgang/vorgang/redirect/EingangForwarderTest.java
+++ b/vorgang-manager-server/src/test/java/de/ozgcloud/vorgang/vorgang/redirect/EingangForwarderTest.java
@@ -95,6 +95,8 @@ class EingangForwarderTest {
 
 		@Mock
 		private GrpcRouteForwarding grpcRouteForwarding;
+		@Mock
+		private ClientCallStreamObserver<GrpcRouteForwardingRequest> requestObserver;
 		private final List<IncomingFileGroup> attachments = List.of(IncomingFileGroupTestFactory.create());
 		private final List<IncomingFile> representations = List.of(IncomingFileTestFactory.create());
 		@Mock
@@ -107,6 +109,7 @@ class EingangForwarderTest {
 			doNothing().when(forwarder).sendAttachments(any());
 			doNothing().when(forwarder).sendRepresentations(any());
 			doNothing().when(forwarder).waitForCompletion(any());
+			setRequestObserverInForwarder(requestObserver);
 		}
 
 		@Test
@@ -137,6 +140,13 @@ class EingangForwarderTest {
 			verify(forwarder).sendRepresentations(representations);
 		}
 
+		@Test
+		void shouldCompleteRequest() {
+			forwarder.forward(grpcRouteForwarding, attachments, representations);
+
+			verify(requestObserver).onCompleted();
+		}
+
 		@Test
 		void shouldWaitForCompletion() {
 			forwarder.forward(grpcRouteForwarding, attachments, representations);