(graph: Dagre.Graph,
idTable: IdTable,
inStream: Stream<any>,
operator: InternalProducer,
outStream: Stream<any>)
| 110 | } |
| 111 | |
| 112 | function visitEdge(graph: Dagre.Graph, |
| 113 | idTable: IdTable, |
| 114 | inStream: Stream<any>, |
| 115 | operator: InternalProducer, |
| 116 | outStream: Stream<any>) { |
| 117 | makeSureNodeIsRegistered(graph, idTable, inStream); |
| 118 | makeSureNodeIsRegistered(graph, idTable, outStream); |
| 119 | graph.setEdge(idTable.getId(inStream), idTable.getId(operator), {}); |
| 120 | graph.setEdge(idTable.getId(operator), idTable.getId(outStream), {}); |
| 121 | if (!inStream['_isCycleSource']) { |
| 122 | traverse(graph, idTable, inStream); |
| 123 | } |
| 124 | } |
| 125 | |
| 126 | function traverse(graph: Dagre.Graph, idTable: IdTable, outStream: Stream<any>) { |
| 127 | if (outStream._prod && outStream._prod['ins']) { |
no test coverage detected