kthompson / actress Goto Github PK

void Main()
{
    var printerAgent = MailboxProcessor.Start<Message>(async mb =>
    {
        var sharedResource = 0;
        while (true)
        {
            var value = await mb.Receive();
            value.Dump("Received");
            if (value is Fetch f)
            {
                f.Channel.Reply(sharedResource);
            }
        }
    });
    
    using (printerAgent)
    {
        printerAgent.DefaultTimeout = int.MaxValue;
        printerAgent.PostAndReply<int>(channel => new Fetch(channel)).Dump("Reply");
    }
}

// Define other methods and classes here
public abstract class Message
{
}

public class Fetch : Message
{
    public Fetch(IReplyChannel<int> channel)
    {
        Channel = channel;
    }
    
    public IReplyChannel<int> Channel { get; }
}