Browse Source

nowait -> async

xf 9 months ago
parent
commit
aaa9c45c60
1 changed files with 3 additions and 3 deletions
  1. 3 3
      src/Hotline/FlowEngine/Workflows/WorkflowDomainService.cs

+ 3 - 3
src/Hotline/FlowEngine/Workflows/WorkflowDomainService.cs

@@ -659,7 +659,7 @@ namespace Hotline.FlowEngine.Workflows
             await _workflowRepository.UpdateAsync(workflow, cancellationToken);
 
             await _publisher.PublishAsync(new PreviousNotify(workflow, newPrevStep, dto, isOrgToCenter),
-                PublishStrategy.ParallelNoWait, cancellationToken);
+                PublishStrategy.Async, cancellationToken);
 
             return GetFlowDirection(currentStep.BusinessType, prevStep.BusinessType);
         }
@@ -1051,7 +1051,7 @@ namespace Hotline.FlowEngine.Workflows
             await _workflowRepository.UpdateAsync(workflow, cancellationToken);
 
             await _publisher.PublishAsync(new RecallNotify(workflow, targetStep, dto, isOrgToCenter),
-                PublishStrategy.ParallelNoWait, cancellationToken);
+                PublishStrategy.Async, cancellationToken);
         }
 
         /// <summary>
@@ -1122,7 +1122,7 @@ namespace Hotline.FlowEngine.Workflows
             var dto = _mapper.Map<RecallDto>(targetStep);
             dto.WorkflowId = workflow.Id;
             await _publisher.PublishAsync(new RecallNotify(workflow, targetStep, dto, isOrgToCenter),
-                PublishStrategy.ParallelNoWait, cancellationToken);
+                PublishStrategy.Async, cancellationToken);
         }
 
         ///// <summary>