LoanApplicationFlow1.cs

using Cleipnir.Flows.Sample.Presentation.Solutions.D_LoanApplication.Other;

namespace Cleipnir.Flows.Sample.Presentation.Solutions.D_LoanApplication;

public class LoanApplicationFlow1 : Flow<LoanApplication>
{
    public override async Task Run(LoanApplication loanApplication)
    {
        await MessageBroker.Send(new PerformCreditCheck(loanApplication.Id, loanApplication.CustomerId, loanApplication.Amount));

        var outcomes = new List<CreditCheckOutcome>();
        for (var i = 0; i < 3; i++)
        {
            var outcome = await Message<CreditCheckOutcome>(TimeSpan.FromMinutes(15));
            if (outcome == null) break;
            outcomes.Add(outcome);
        }

        CommandAndEvents decision = outcomes.All(o => o.Approved)
            ? new LoanApplicationApproved(loanApplication)
            : new LoanApplicationRejected(loanApplication);

        await MessageBroker.Send(decision);
    }
}