code: private void work() {
          if (next.equals(END)) {
              end();
          } else {
              Map<String, Object> params = processParams();
              LOG.info("[RuleController] params = " + params);
              SingleRxXian
                      .call(next.split("_")[0], next.split("_")[1], params)
                      .subscribe(unitResponse1 -> {
                          unitResponse = unitResponse1;
                          processReturnParams();
                          callNext();
                          work();
                      });
          }
      }
docs: 执行