From afa8027af42a8f32b7e95fa56b5636957b6955ef Mon Sep 17 00:00:00 2001
From: Paul-Christian Volkmer <code@pcvolkmer.de>
Date: Mon, 5 Aug 2024 19:55:43 +0200
Subject: [PATCH] feat: use directBestEffort sink

---
 .../oncoanalytics/monitor/OncoAnalyticsMonitorApplication.kt    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/kotlin/dev/pcvolkmer/oncoanalytics/monitor/OncoAnalyticsMonitorApplication.kt b/src/main/kotlin/dev/pcvolkmer/oncoanalytics/monitor/OncoAnalyticsMonitorApplication.kt
index aef3875..2e8239e 100644
--- a/src/main/kotlin/dev/pcvolkmer/oncoanalytics/monitor/OncoAnalyticsMonitorApplication.kt
+++ b/src/main/kotlin/dev/pcvolkmer/oncoanalytics/monitor/OncoAnalyticsMonitorApplication.kt
@@ -14,7 +14,7 @@ class OncoAnalyticsMonitorApplication {
 
     @Bean
     fun statisticsEventProducer(): StatisticsSink {
-        return Sinks.many().multicast().onBackpressureBuffer()
+        return Sinks.many().multicast().directBestEffort()
     }
 
     @Bean