Saga 2.3

AccountProxy.cs

class AccountProxy : IActor
{
    private readonly PID _account;
    private readonly Func<PID, object> _createMessage;

    public AccountProxy(PID account, Func<PID, object> createMessage)
    {
        _account = account;
        _createMessage = createMessage;
    }
    
    public Task ReceiveAsync(IContext context)
    {
        switch (context.Message)
        {
            case Started _:
                _account.Tell(_createMessage(context.Self));
                context.SetReceiveTimeout(TimeSpan.FromMilliseconds(100));
                break;
            case OK msg:
                context.CancelReceiveTimeout();
                context.Parent.Tell(msg);
                break;
            case Refused msg:
                context.CancelReceiveTimeout();
                context.Parent.Tell(msg);
                break;
            // These represent a failed remote call
            case InternalServerError _:
            case ReceiveTimeout _:
            case ServiceUnavailable _:
                throw new Exception();
        }
        
        return Actor.Done;
    }
}