mirror of https://github.com/dapr/docs.git
Fixed mismatched variable name
Signed-off-by: Whit Waldo <whit.waldo@innovian.net>
This commit is contained in:
parent
8ddb88f912
commit
3259b08e4e
|
|
@ -637,7 +637,7 @@ concurrency by using the following extension methods on the `WorkflowContext`:
|
||||||
var workBatch = await context.CallActivityAsync<object[]>("GetWorkBatch", null);
|
var workBatch = await context.CallActivityAsync<object[]>("GetWorkBatch", null);
|
||||||
|
|
||||||
// Process deterministically in parallel with an upper cap of 5 activities at a time
|
// Process deterministically in parallel with an upper cap of 5 activities at a time
|
||||||
var results = await context.ProcessInParallelAsync(workBatch, batch => context.CallActivityAsync<int>("ProcessWorkItem", workItem), maxConcurrency: 5);
|
var results = await context.ProcessInParallelAsync(workBatch, workItem => context.CallActivityAsync<int>("ProcessWorkItem", workItem), maxConcurrency: 5);
|
||||||
|
|
||||||
var sum = results.Sum(t => t);
|
var sum = results.Sum(t => t);
|
||||||
await context.CallActivityAsync("PostResults", sum);
|
await context.CallActivityAsync("PostResults", sum);
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue