Extend RunWorkflowSync

Extend RunWorkflowSync using a CancelationToken

Author: xlegalles

src/WorkflowCore/Interface/ISyncWorkflowRunner.cs

@@ -1,4 +1,5 @@
 using System;
+using System.Threading;
 using System.Threading.Tasks;
 using WorkflowCore.Models;
 
@@ -8,5 +9,8 @@ public interface ISyncWorkflowRunner
     {
         Task<WorkflowInstance> RunWorkflowSync<TData>(string workflowId, int version, TData data, string reference, TimeSpan timeOut, bool persistSate = true)
             where TData : new();
+
+        Task<WorkflowInstance> RunWorkflowSync<TData>(string workflowId, int version, TData data, string reference, CancellationToken token, bool persistSate = true)
+            where TData : new();
     }
 }

src/WorkflowCore/Services/SyncWorkflowRunner.cs

@@ -32,7 +32,15 @@ public SyncWorkflowRunner(IWorkflowHost host, IWorkflowExecutor executor, IDistr
             _dateTimeProvider = dateTimeProvider;
         }
 
-        public async Task<WorkflowInstance> RunWorkflowSync<TData>(string workflowId, int version, TData data, string reference, TimeSpan timeOut, bool persistSate = true)
+        public Task<WorkflowInstance> RunWorkflowSync<TData>(string workflowId, int version, TData data,
+            string reference, TimeSpan timeOut, bool persistSate = true)
+            where TData : new()
+        {
+            return RunWorkflowSync(workflowId, version, data, reference, new CancellationTokenSource(timeOut).Token,
+                persistSate);
+        }
+
+        public async Task<WorkflowInstance> RunWorkflowSync<TData>(string workflowId, int version, TData data, string reference, CancellationToken token, bool persistSate = true)
             where TData : new()
         {
             var def = _registry.GetDefinition(workflowId, version);