async steps

Author: danielgerlag

src/WorkflowCore/Interface/IStepBody.cs

@@ -8,6 +8,6 @@ namespace WorkflowCore.Interface
 {
     public interface IStepBody
     {        
-        ExecutionResult Run(IStepExecutionContext context);
+        Task<ExecutionResult> RunAsync(IStepExecutionContext context);
     }
 }

src/WorkflowCore/Models/StepBody.cs

@@ -8,9 +8,14 @@ namespace WorkflowCore.Models
 {
     public abstract class StepBody : IStepBody
     {
-        
+
         public abstract ExecutionResult Run(IStepExecutionContext context);
 
+        public Task<ExecutionResult> RunAsync(IStepExecutionContext context)
+        {
+            return Task.FromResult(Run(context));
+        }
+
         protected ExecutionResult OutcomeResult(object value)
         {
             return new ExecutionResult()

src/WorkflowCore/Models/StepBodyAsync.cs

@@ -0,0 +1,14 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+using WorkflowCore.Interface;
+
+namespace WorkflowCore.Models
+{
+    public abstract class StepBodyAsync : IStepBody
+    {
+        public abstract Task<ExecutionResult> RunAsync(IStepExecutionContext context);
+        
+    }
+}

src/WorkflowCore/Services/WorkflowExecutor.cs

@@ -100,7 +100,7 @@ public async Task<WorkflowExecutorResult> Execute(WorkflowInstance workflow, Wor
                                 continue;
                         }
 
-                        var result = body.Run(context);
+                        var result = await body.RunAsync(context);
 
                         ProcessOutputs(workflow, step, body);
                         ProcessExecutionResult(workflow, def, pointer, step, result, wfResult);

test/WorkflowCore.UnitTests/Services/WorkflowExecutorFixture.cs

@@ -80,7 +80,7 @@ public WorkflowExecutorFixture()
 
             Registry = serviceProvider.GetService<IWorkflowRegistry>();
 
-            Subject = new WorkflowExecutor(Host, Registry, serviceProvider, new DateTimeProvider(), loggerFactory);            
+            Subject = new WorkflowExecutor(Registry, serviceProvider, new DateTimeProvider(), loggerFactory);            
         }
 
         [Fact]