VertX多个期货返回一个期货

我正在尝试调用3个Future，等待它们完成，处理结果，然后将所有这些作为Future返回。我似乎不知道如何"；"包裹"；未来的3个期货将被退回，这样它就不会立即退回。我是vertx的新手。

public Future<MyObject> getProjectStatus(int projectId) {
Future future = Future.future(ar -> {
MyObject object = new Myobject();
Future<x> f1 = callf1();
Future<y> f2 = callf2();
Future<z> f3 = callf3();
CompositeFuture cf = CompositeFuture.all(f1, f2, f3);
cf.onComplete(ar2 -> {
//Check Succeeds
if(ar2.succeeded()){
System.out.println("Completed!");
//DO FURTHER PROCESSING
} else {
System.out.println("Failure " + ar2.cause().getMessage());
}
}).map((object));
});
return future;
}


public Future<MyObject> getProjectStatus(int projectId) {
MyObject object = new Myobject();
Future<x> f1 = callf1();
Future<y> f2 = callf2();
Future<z> f3 = callf3();
return CompositeFuture.all(f1, f2, f3).onComplete(ar2 -> {
//Check Succeeds
if(ar2.succeeded()){
System.out.println("Completed!");
//DO FURTHER PROCESSING
} else {
System.out.println("Failure " + ar2.cause().getMessage());
}
}).map(object);
}

或

public Future<MyObject> getProjectStatus(int projectId) {
Future future = Future.future(ar -> {
MyObject object = new Myobject();
Future<x> f1 = callf1();
Future<y> f2 = callf2();
Future<z> f3 = callf3();
CompositeFuture cf = CompositeFuture.all(f1, f2, f3);
cf.onComplete(ar2 -> {
//Check Succeeds
if(ar2.succeeded()){
System.out.println("Completed!");
//DO FURTHER PROCESSING
} else {
System.out.println("Failure " + ar2.cause().getMessage());
}
ar.complete(object);
});
});
return future;
}

相关内容

最新更新

热门标签：