Merge pull request danielgerlag#895 from vladimir-kovalyuk/issues/894

Fix issue 894

Author: danielgerlag

src/WorkflowCore/Primitives/Foreach.cs

@@ -15,7 +15,12 @@ public override ExecutionResult Run(IStepExecutionContext context)
         {
             if (context.PersistenceData == null)
             {
-                var values = Collection.Cast<object>();
+                var values = Collection.Cast<object>().ToList();
+                if (!values.Any())
+                {
+                    return ExecutionResult.Next();
+                }
+
                 if (RunParallel)
                 {
                     return ExecutionResult.Branch(new List<object>(values), new IteratorPersistenceData { ChildrenActive = true });

test/WorkflowCore.IntegrationTests/Scenarios/ForeachScenario.cs

@@ -18,7 +18,6 @@ public class ForeachScenario : WorkflowTest<ForeachScenario.ForeachWorkflow, For
 
         public class DoSomething : StepBody
         {
-            
             public override ExecutionResult Run(IStepExecutionContext context)
             {
                 Step2Ticker++;
@@ -29,6 +28,9 @@ public override ExecutionResult Run(IStepExecutionContext context)
 
         public class MyDataClass
         {
+            public List<int> Numbers { get; set; } = new List<int>();
+
+            public bool IsParallel { get; set; } = true;
         }
 
         public class ForeachWorkflow : IWorkflow<MyDataClass>
@@ -43,7 +45,7 @@ public void Build(IWorkflowBuilder<MyDataClass> builder)
                         Step1Ticker++;
                         return ExecutionResult.Next();
                     })
-                    .ForEach(x => new List<int> { 2, 2, 3 })
+                    .ForEach(x => x.Numbers, x => x.IsParallel)
                         .Do(x => x.StartWith<DoSomething>())                    
                     .Then(context =>
                     {
@@ -57,12 +59,18 @@ public void Build(IWorkflowBuilder<MyDataClass> builder)
         public ForeachScenario()
         {
             Setup();
+
+            Step1Ticker = 0;
+            Step2Ticker = 0;
+            Step3Ticker = 0;
+            AfterLoopValue = 0;
+            CheckSum = 0;
         }
 
         [Fact]
         public void Scenario()
         {
-            var workflowId = StartWorkflow(null);
+            var workflowId = StartWorkflow(new MyDataClass { Numbers = new List<int> { 2, 2, 3 } });
             WaitForWorkflowToComplete(workflowId, TimeSpan.FromSeconds(30));
 
             Step1Ticker.Should().Be(1);
@@ -73,5 +81,20 @@ public void Scenario()
             GetStatus(workflowId).Should().Be(WorkflowStatus.Complete);
             UnhandledStepErrors.Count.Should().Be(0);
         }
+
+        [Fact]
+        public void EmptyCollectionSequentialScenario()
+        {
+            var workflowId = StartWorkflow(new MyDataClass { IsParallel = false });
+            WaitForWorkflowToComplete(workflowId, TimeSpan.FromSeconds(30));
+
+            GetStatus(workflowId).Should().Be(WorkflowStatus.Complete);
+            UnhandledStepErrors.Count.Should().Be(0);
+            Step1Ticker.Should().Be(1);
+            Step2Ticker.Should().Be(0);
+            Step3Ticker.Should().Be(1);
+            AfterLoopValue.Should().Be(0);
+            CheckSum.Should().Be(0);
+        }
     }
 }