From 78ad103151d9dfaf4019c4f2b26d330cc6ec3e74 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Mike=20Schw=C3=B6rer?= <pubgit@mikescher.com>
Date: Sat, 20 Sep 2025 15:19:09 +0200
Subject: [PATCH] v0.0.603

---
 dataext/delayedCombiningInvoker.go | 13 ++++++++++---
 goextVersion.go                    |  4 ++--
 2 files changed, 12 insertions(+), 5 deletions(-)

diff --git a/dataext/delayedCombiningInvoker.go b/dataext/delayedCombiningInvoker.go
index dde330a..83afffe 100644
--- a/dataext/delayedCombiningInvoker.go
+++ b/dataext/delayedCombiningInvoker.go
@@ -79,10 +79,14 @@ func (d *DelayedCombiningInvoker) Request() {
 }
 
 func (d *DelayedCombiningInvoker) run() {
+
+	needsExecutorRunningCleanup := true
 	defer func() {
-		d.syncLock.Lock()
-		d.executorRunning.Set(false)
-		d.syncLock.Unlock()
+		if needsExecutorRunningCleanup {
+			d.syncLock.Lock()
+			d.executorRunning.Set(false)
+			d.syncLock.Unlock()
+		}
 	}()
 
 	for {
@@ -129,6 +133,9 @@ func (d *DelayedCombiningInvoker) run() {
 		_ = langext.RunPanicSafe(d.action)
 		// =================================================
 
+		d.executorRunning.Set(false) // ensure HasPendingRequests returns fals ein onExecutionDone listener
+		needsExecutorRunningCleanup = false
+
 		for _, fn := range d.onExecutionDone {
 			_ = langext.RunPanicSafe(fn)
 		}
diff --git a/goextVersion.go b/goextVersion.go
index 6094180..6a5bfdc 100644
--- a/goextVersion.go
+++ b/goextVersion.go
@@ -1,5 +1,5 @@
 package goext
 
-const GoextVersion = "0.0.602"
+const GoextVersion = "0.0.603"
 
-const GoextVersionTimestamp = "2025-09-20T15:13:02+0200"
+const GoextVersionTimestamp = "2025-09-20T15:19:09+0200"