mirror of https://github.com/dapr/quickstarts.git
Update tutorials/workflow/java/child-workflows/src/main/java/io/dapr/springboot/examples/child/ParentWorkflow.java
Co-authored-by: Marc Duiker <marcduiker@users.noreply.github.com> Signed-off-by: salaboy <Salaboy@gmail.com>
This commit is contained in:
parent
7a03ef7acd
commit
c420cb198e
|
|
@ -34,7 +34,7 @@ public class ParentWorkflow implements Workflow {
|
||||||
.map(input -> ctx.callChildWorkflow(ChildWorkflow.class.getName(), input, String.class))
|
.map(input -> ctx.callChildWorkflow(ChildWorkflow.class.getName(), input, String.class))
|
||||||
.collect(Collectors.toList());
|
.collect(Collectors.toList());
|
||||||
|
|
||||||
// Fan-in to get the total word count from all the individual activity results.
|
// Fan-out & fan-in to get the all the child workflow results.
|
||||||
List<String> allChildWorkflowsResults = ctx.allOf(tasks).await();
|
List<String> allChildWorkflowsResults = ctx.allOf(tasks).await();
|
||||||
|
|
||||||
ctx.complete(allChildWorkflowsResults);
|
ctx.complete(allChildWorkflowsResults);
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue