fix mailboxempty issue

asynkron · Apr 8, 2024 · f4cee9b · f4cee9b
1 parent 59d175c
commit f4cee9b
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/actor/mailbox.go b/actor/mailbox.go
@@ -117,8 +117,10 @@ process:
 		}
 	}
 
-	for _, ms := range m.middlewares {
-		ms.MailboxEmpty()
+	if user == 0 && (atomic.LoadInt32(&m.suspended) == 0) {
+		for _, ms := range m.middlewares {
+			ms.MailboxEmpty()
+		}
 	}
 }
 

diff --git a/examples/actor-mailbox-middleware/main.go b/examples/actor-mailbox-middleware/main.go
@@ -2,6 +2,7 @@ package main
 
 import (
 	"log/slog"
+	"time"
 
 	console "github.com/asynkron/goconsole"
 	"github.com/asynkron/protoactor-go/actor"
@@ -36,5 +37,7 @@ func main() {
 	)
 	pid := rootContext.Spawn(props)
 	rootContext.Send(pid, "Hello")
+	time.Sleep(1 * time.Second)
+	rootContext.Send(pid, "Hello")
 	_, _ = console.ReadLine()
 }