VERTX-将参数从一个组合到另一个

Question

我需要一些帮助才能将参数从一个组合传递到另一个参数。如下所示，我想将第二个构图的标签置术传递到最后一个组合中。

public Future<JsonArray> startTest(int jobID, RoutingContext context) {
    LOG.info("-----INside startTest() method-----");
    return jobDao.getJob(jobID, context)
            .compose(job -> productDao.getLabelParameters(job, context))
            .compose(labelParameters -> jobDao.getJobParentChildForPrint(jobID, context, true, labelParameters))
            .compose(parentChildSerials -> {
                    LOG.debug(" Future Returned Job Parent-Child to Print: ");
                    prepareSerialForPrint(parentChildSerials, labelParameters); //Pass Here 
                    return Future.succeededFuture(parentChildSerials);
            })
        .onFailure(error -> {
                LOG.debug("startTest() Failed: ", error);
              })
        .onSuccess(server -> {
                LOG.debug("Finished startTest!!");
                LOG.debug(server.encodePrettily());
              });
}

Answer 1

您可以为期货中传递的数据创建一个具有setter/getter的上下文对象。
撰写期货的guareantees串行执行，您可以设置结果，并假设下一个撰写部分中的上下文对象中存在该结果。示例：

public Future<JsonArray> startTest(int jobID, RoutingContext context) {
    MyTestContext myTestCtx = new MyTestConext();

    return jobDao.getJob(jobID, context)
            .compose(job -> {
                myTestCtx.setjob(job);
                return productDao.getLabelParameters(job, context);
            })
            .compose(labelParameters -> {
                myTestCtx.setLabelParameters(labelparameters);
                return jobDao.getJobParentChildForPrint(jobID, context, true, labelParameters);
            })
            .compose(parentChildSerials -> {
                var labelParameters = myTestCtx.getLabelParameters();
                prepareSerialForPrint(parentChildSerials, labelParameters); //Pass Here 
                return Future.succeededFuture(parentChildSerials);
            })
        .onSuccess(server -> LOG.debug("Finished startTest!!"));

}

您还可以为此使用Java记录。

另外，您可以如下嵌套组合零件：

    public Future<JsonArray> startTest(int jobID, RoutingContext context) {
        return jobDao.getJob(jobID, context)
                .compose(job -> productDao.getLabelParameters(job, context))
                .compose(labelParameters -> {
                    return jobDao.getJobParentChildForPrint(jobID, context, true, labelParameters)
                            .compose(parentChildSerials -> {
                                LOG.debug(" Future Returned Job Parent-Child to Print: ");
                                prepareSerialForPrint(parentChildSerials, labelParameters); //Pass Here 
                                return Future.succeededFuture(parentChildSerials);
                            })
                })    
            .onFailure(error -> LOG.debug("startTest() Failed: ", error))
            .onSuccess(server -> LOG.debug(server.encodePrettily()));
    
    }