Skip to content

Commit

Permalink
fixed docu
Browse files Browse the repository at this point in the history
  • Loading branch information
sebogh committed Jun 26, 2022
1 parent bb7d59d commit 8ca1b65
Showing 1 changed file with 4 additions and 3 deletions.
7 changes: 4 additions & 3 deletions dag.go
Original file line number Diff line number Diff line change
Expand Up @@ -891,9 +891,10 @@ type FlowResult struct {
// should return a result or an error.
type FlowCallback func(d *DAG, id string, parentResults []FlowResult) (interface{}, error)

// DescendantsFlow traverses descendants of the given start vertex (startID). For
// each descendant it executes the given (callback-) function (FlowCallback), if all parents
// have finished their work. The
// DescendantsFlow traverses descendants of the vertex with the ID startID. For
// the vertex itself and each of its descendant it executes the given (callback-)
// function providing it the results of its respective parents. The (callback-)
// function is only executed after all parents have finished their work.
func (d *DAG) DescendantsFlow(startID string, inputs []FlowResult, callback FlowCallback) ([]FlowResult, error) {
d.muDAG.RLock()
defer d.muDAG.RUnlock()
Expand Down

0 comments on commit 8ca1b65

Please sign in to comment.