Added statistics update using SSE for delete requests

1 files changed, 4 insertions, 0 deletions

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