an agent that dies

dyingagent.fs

type EventPublisher (eventBus, logger) =
    let agent eventBus (logger : ILoggingService) =
        new Agent<EventAggregateMessage>(
            fun inbox ->
                let rec loop () = async {
                    let! message = inbox.Receive()
                    match message with
                    | EventAggregate aggregate ->
                        try
                            let playerId = aggregate.PlayerScope.PlayerId.ToString()
                            logger.logInfo playerId aggregate.CorrelationToken "sending to bus"
                            let message = AggregateMapper.toMessageContract aggregate
                            do! publish eventBus message
                            logger.logInfo  playerId aggregate.CorrelationToken "handled message"
                        with
                        | _ as e -> 
                            logger.logError e ""

                        return! loop ()
                    | Die -> return () }
                loop ())