From 3f2c8c23d5745493b20bf4c166e94015d2e7803c Mon Sep 17 00:00:00 2001
From: ogesaku <ogesaku@gmail.com>
Date: Sun, 18 Feb 2024 19:44:45 +0100
Subject: [PATCH] Simplify log listeners

---
 .../com/coditory/klog/LogPublisherListener.kt  | 18 +++++++++++++++---
 .../com/coditory/klog/LogStreamListener.kt     |  6 +++++-
 2 files changed, 20 insertions(+), 4 deletions(-)

diff --git a/klog/src/main/kotlin/com/coditory/klog/LogPublisherListener.kt b/klog/src/main/kotlin/com/coditory/klog/LogPublisherListener.kt
index 62e96bf..42bd3d4 100644
--- a/klog/src/main/kotlin/com/coditory/klog/LogPublisherListener.kt
+++ b/klog/src/main/kotlin/com/coditory/klog/LogPublisherListener.kt
@@ -3,15 +3,27 @@ package com.coditory.klog
 interface LogPublisherListener {
     fun onPublishStarted(event: LogEvent) {}
 
-    fun onPublishStarted(events: List<LogEvent>) {}
+    fun onPublishStarted(events: List<LogEvent>) {
+        for (event in events) {
+            onPublishStarted(event)
+        }
+    }
 
     fun onPublishDropped(event: LogEvent, e: Throwable? = null) {}
 
-    fun onPublishDropped(events: List<LogEvent>, e: Throwable? = null) {}
+    fun onPublishDropped(events: List<LogEvent>, e: Throwable? = null) {
+        for (event in events) {
+            onPublishDropped(event, e)
+        }
+    }
 
     fun onPublishEnded(event: LogEvent) {}
 
-    fun onPublishEnded(events: List<LogEvent>) {}
+    fun onPublishEnded(events: List<LogEvent>) {
+        for (event in events) {
+            onPublishEnded(event)
+        }
+    }
 
     companion object {
         internal val NOOP = object : LogPublisherListener {}
diff --git a/klog/src/main/kotlin/com/coditory/klog/LogStreamListener.kt b/klog/src/main/kotlin/com/coditory/klog/LogStreamListener.kt
index 7e97e19..68ace46 100644
--- a/klog/src/main/kotlin/com/coditory/klog/LogStreamListener.kt
+++ b/klog/src/main/kotlin/com/coditory/klog/LogStreamListener.kt
@@ -7,7 +7,11 @@ interface LogStreamListener : LogPublisherListener {
 
     fun onStreamDropped(event: LogEvent, e: Throwable? = null) {}
 
-    fun onStreamDropped(events: List<LogEvent>, e: Throwable? = null) {}
+    fun onStreamDropped(events: List<LogEvent>, e: Throwable? = null) {
+        for (event in events) {
+            onStreamDropped(event, e)
+        }
+    }
 
     companion object {
         internal val NOOP = object : LogStreamListener {}