Vertx Future不会等待

Question

由于我在堆栈中使用Vertx3.1，我想使用这些工具带来的未来特性，但在阅读后，API似乎对我来说相当有限。我甚至找不到方法让未来等待一个可观察的。这里是我的代码

          public Observable<CommitToOrderCommand> validateProductRestrictions(CommitToOrderCommand cmd) {
    Future<Observable<CommitToOrderCommand>> future = Future.future();
    orderRepository.getOrder(cmd, cmd.orderId)
                   .flatMap(order -> validateOrderProducts(cmd, order))
                   .subscribe(map -> checkMapValues(map, future, cmd));
     Observable<CommitToOrderCommand> result = future.result();
    if(errorFound){
        throw MAX_QUANTITY_PRODUCT_EXCEED.create("Fail"/*restrictions.getBulkBuyLimit().getDescription())*/);
    }
    return result;
}

private void checkMapValues(Multimap<String, BigDecimal> totalUnitByRestrictions, Future<Observable<CommitToOrderCommand>> future,
                            CommitToOrderCommand cmd) {
    for (String restrictionName : totalUnitByRestrictions.keySet()) {
        Restrictions restrictions = Restrictions.valueOf(restrictionName);
        if (totalUnitByRestrictions.get(restrictionName)
                                   .stream()
                                   .reduce(BigDecimal.ZERO, BigDecimal::add)
                                   .compareTo(restrictions.getBulkBuyLimit()
                                                          .getMaxQuantity()) == 1) {
            errorFound = true;
        }
    }
    future.complete(Observable.just(cmd));
}

在我第一次观察到的onComplete中，我正在检查结果，在finish之后是当我完成以后解除阻塞的操作。但是我正在寻找未来。结果不会被阻止，直到未来。完成像我期望的那样被调用。而是返回null。

问候。

Answer 1

vertx future不会阻塞，而是使用在注入结果时调用的处理程序（请参见sethandler和iscomplete)。

如果代码的外层需要一个可观察的，您不需要在将来包装它，只需返回Observable 。未来 > 没有太大意义，您混合了两种处理异步结果的方法。

请注意，有一些方法可以将一个可观察到的东西折叠成一个未来，但困难在于，一个可观察到的东西可能会发出几个项目，而一个未来只能容纳一个项目。您已经通过将结果收集到单个map发射中来处理这一点。

由于这个可观察的只发出一个项，如果您想要一个future，您应该subscribue，并在onnext方法中调用future.complete(yourMap)。还要定义一个onerror处理程序，它将调用future.fail。