public void run()

in saga-core/src/main/java/org/apache/servicecomb/saga/core/TaskRunner.java [46:60]

• 12 lines of code
• 3 McCabe index (conditional complexity)

  public void run() {
    Collection<Node<SagaRequest>> nodes = traveller.nodes();

    // finish pending tasks from saga log at startup
    if (!nodes.isEmpty()) {
      taskConsumer.consume(nodes);
      nodes.clear();
    }

    while (traveller.hasNext()) {
      traveller.next();
      taskConsumer.consume(nodes);
      nodes.clear();
    }
  }