SemianiakaVY/elsa-core
1
0
Fork 0
Code Issues Pull requests Actions 1 Packages Projects Releases Wiki Activity

Add ForEach sample workflow

Browse source
This commit is contained in:
Sipke Schoorstra 2022-11-10 16:24:10 +01:00
parent 5e35dad9e7
commit 1300a92118
2 changed files with 50 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
src/samples/console/Elsa.Samples.LoopingWorkflows/Program.cs
View file

@ -15,5 +15,8 @@ var serviceProvider = services.BuildServiceProvider();
// Resolve a workflow runner to run the workflow.
var workflowRunner = serviceProvider.GetRequiredService<IWorkflowRunner>();
// Run the ForWorkflow.
await workflowRunner.RunAsync(ForWorkflow.Create());
// Run the For workflow.
await workflowRunner.RunAsync(ForWorkflow.Create());
// Run the For Each workflow.
await workflowRunner.RunAsync(ForEachWorkflow.Create());

45
src/samples/console/Elsa.Samples.LoopingWorkflows/Workflows/ForEachWorkflow.cs Normal file
View file

@ -0,0 +1,45 @@
using Elsa.Expressions.Models;
using Elsa.Scheduling.Activities;
using Elsa.Scheduling.Models;
using Elsa.Workflows.Core.Activities;
using Elsa.Workflows.Core.Models;
using Elsa.Workflows.Core.Services;
namespace Elsa.Samples.LoopingWorkflows.Workflows;
public static class ForEachWorkflow
{
public static IActivity Create()
{
var currentValueVariable = new Variable<string>();
var shoppingList = new[] { "Apples", "Bananas", "Potatoes", "Coffee", "Honey", "Rice" };
return new Sequence
{
Variables = { currentValueVariable },
Activities =
{
new WriteLine("Going through the shopping list..."),
new ForEach(shoppingList)
{
CurrentValue = new Output<object>(currentValueVariable),
Body = new Sequence
{
Activities =
{
new WriteLine(context => $"- [ ] {currentValueVariable.Get(context)}"),
new Delay
{
// The strategy determines whether the workflow should suspend or wait synchronously.
// For console applications without a host, long-running workflows aren't supported, so we use the Blocking strategy.
Strategy = new Input<DelayBlockingStrategy>(DelayBlockingStrategy.Blocking),
TimeSpan = new Input<TimeSpan>(TimeSpan.FromMilliseconds(250))
}
}
}
},
new WriteLine("Let's not forget anything!")
}
};
}
}