File tree Expand file tree Collapse file tree 1 file changed +3
-6
lines changed
WorkflowConcurrency/Sources Expand file tree Collapse file tree 1 file changed +3
-6
lines changed Original file line number Diff line number Diff line change @@ -55,7 +55,9 @@ struct AsyncSequenceWorkerWorkflow<WorkerType: AsyncSequenceWorker>: Workflow {
55
55
guard let output = output as? Output else {
56
56
fatalError ( " Unexpected output type \( type ( of: output) ) from worker \( worker) " )
57
57
}
58
- await sendAction ( output: output, sink: sink)
58
+ await MainActor . run {
59
+ sink. send ( AnyWorkflowAction ( sendingOutput: output) )
60
+ }
59
61
}
60
62
}
61
63
@@ -64,9 +66,4 @@ struct AsyncSequenceWorkerWorkflow<WorkerType: AsyncSequenceWorker>: Workflow {
64
66
}
65
67
}
66
68
}
67
-
68
- @MainActor
69
- func sendAction( output: Output , sink: Sink < AnyWorkflowAction < AsyncSequenceWorkerWorkflow < WorkerType > > > ) {
70
- sink. send ( AnyWorkflowAction ( sendingOutput: output) )
71
- }
72
69
}
You can’t perform that action at this time.
0 commit comments