Skip to content

Commit 28035fe

Browse files
committed
fix conflicts
1 parent 15b5dc3 commit 28035fe

File tree

2 files changed

+12
-0
lines changed

2 files changed

+12
-0
lines changed

src/WorkflowCore/Interface/IWorkflowModifier.cs

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -83,6 +83,13 @@ IStepBuilder<TData, WaitFor> WaitFor(string eventName,
8383
/// <param name="collection">Resolves a collection for iterate over</param>
8484
/// <returns></returns>
8585
IContainerStepBuilder<TData, Foreach, Foreach> ForEach(Expression<Func<TData, IEnumerable>> collection);
86+
87+
/// <summary>
88+
/// Execute a block of steps, once for each item in a collection in a RunParallel foreach
89+
/// </summary>
90+
/// <param name="collection">Resolves a collection for iterate over</param>
91+
/// <returns></returns>
92+
IContainerStepBuilder<TData, Foreach, Foreach> ForEach(Expression<Func<TData, IEnumerable>> collection, Expression<Func<TData, bool>> runParallel);
8693

8794
/// <summary>
8895
/// Repeat a block of steps until a condition becomes true

src/WorkflowCore/Services/FluentBuilders/WorkflowBuilder.cs

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -197,6 +197,11 @@ public IContainerStepBuilder<TData, Foreach, Foreach> ForEach(Expression<Func<TD
197197
{
198198
return Start().ForEach(collection);
199199
}
200+
201+
public IContainerStepBuilder<TData, Foreach, Foreach> ForEach(Expression<Func<TData, IEnumerable>> collection, Expression<Func<TData, bool>> runParallel)
202+
{
203+
return Start().ForEach(collection, runParallel);
204+
}
200205

201206
public IContainerStepBuilder<TData, While, While> While(Expression<Func<TData, bool>> condition)
202207
{

0 commit comments

Comments
 (0)