From ccf6908223743af7c9219571fea7f6ba48053463 Mon Sep 17 00:00:00 2001
From: Paul-Christian Volkmer <volkmer_p@ukw.de>
Date: Tue, 1 Aug 2023 13:54:26 +0200
Subject: [PATCH] Added statistics update using SSE for delete requests

---
 .../dev/dnpm/etl/processor/services/RequestProcessor.kt       | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/src/main/kotlin/dev/dnpm/etl/processor/services/RequestProcessor.kt b/src/main/kotlin/dev/dnpm/etl/processor/services/RequestProcessor.kt
index cd3a525..8588ebe 100644
--- a/src/main/kotlin/dev/dnpm/etl/processor/services/RequestProcessor.kt
+++ b/src/main/kotlin/dev/dnpm/etl/processor/services/RequestProcessor.kt
@@ -179,6 +179,8 @@ class RequestProcessor(
                 )
             )
 
+            statisticsUpdateProducer.emitNext("", Sinks.EmitFailureHandler.FAIL_FAST)
+
             return overallRequestStatus
         } catch (e: Exception) {
             requestRepository.save(
@@ -193,6 +195,8 @@ class RequestProcessor(
                 )
             )
 
+            statisticsUpdateProducer.emitNext("", Sinks.EmitFailureHandler.FAIL_FAST)
+
             return RequestStatus.ERROR
         }
     }