Saga 5.2

Runner.cs

public Task ReceiveAsync(IContext context)
{
    switch (context.Message)
    {
        //...
        case Started _:
            var random = new Random();
            _inMemoryProvider = new InMemoryProvider();

            for (int i = 1; i <= _numberOfIterations; i++)
            {
                int j = i;
                var fromAccount = CreateAccount($"FromAccount{j}", random);
                var toAccount = CreateAccount($"ToAccount{j}", random);

                var transferProps = Actor.FromProducer(() => new TransferProcess(fromAccount, toAccount, 10,
                        _inMemoryProvider, $"Transfer Process {j}", random, _uptime))
                    .WithChildSupervisorStrategy(
                        new OneForOneStrategy((pid, reason) => SupervisorDirective.Restart, _retryAttempts,
                            null));

                var transfer = context.SpawnNamed(transferProps, $"Transfer Process {j}");
                _transfers.Add(transfer);
            
            }
            break;
    }
    return Actor.Done;
}