FuncWorkflowBuilder.workflow("listenToOneReviewCol")
.tasks(
listen("waitReview", toOne("org.acme.test.review"))
.outputAs((Collection node) -> node.iterator().next()))
FuncWorkflowBuilder.workflow("listenToOneReviewNode")
.tasks(
listen("waitReview", toOne("org.acme.test.review"))
.outputAs((ArrayNode node) -> node.get(0))