OZG-7573 OZG-7991 Complete request

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);
 	}
 

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);