simplify the event stream handling. remove special handling of deadle…

…tters.

actor/event_stream.go

@@ -2,7 +2,6 @@ package actor
 
 import (
 	"context"
-	"fmt"
 	"log/slog"
 )
 
@@ -25,25 +24,8 @@ func (e *EventStream) Receive(c *Context) {
 	switch msg := c.Message().(type) {
 	case EventSub:
 		e.subs[msg.pid] = true
-		fmt.Println("EventStream.Receive: EventSub")
 	case EventUnsub:
 		delete(e.subs, msg.pid)
-		fmt.Println("EventStream.Receive: EventUnsub")
-	case DeadLetterEvent:
-		// to avoid a loop, check that the message isn't a deadletter.
-		_, ok := msg.Message.(DeadLetterEvent)
-		if ok {
-			c.engine.BroadcastEvent(DeadLetterLoopEvent{})
-			break
-		}
-		if len(e.subs) == 0 {
-			slog.Warn("deadletter arrived, but no subscribers to event stream",
-				"sender", msg.Sender, "target", msg.Target, "msg", msg.Message)
-			break
-		}
-		for sub := range e.subs {
-			c.Forward(sub)
-		}
 	default:
 		// check if we should log the event, if so, log it with the relevant level, message and attributes
 		logMsg, ok := c.Message().(eventLog)