handleJoinNode method

void handleJoinNode(
  1. NodeOutput item,
  2. State state,
  3. TraverseQueue levelQueue
)

Implementation

void handleJoinNode(NodeOutput item, State state, TraverseQueue levelQueue) {
  var queue = state.queue, mtx = state.mtx;
  if (joinHasUnresolvedIncomes(item)) {
    queue.push(item);
    return;
  }
  resolveCurrentJoinIncomes(mtx, item);
  bool isInserted = processOrSkipNodeOnMatrix(item, state);
  if (isInserted) {
    insertJoinIncomes(item, state, levelQueue, true);
  }
}