飞镖等待内心的未来

Question

我正在尝试执行一些相互引用作为外键的查询，因此我必须等到外部未来完成。此算法放置在返回未来的函数中。

Future<List<int>> newEntry(Session session) {
    bool success = true;
    List<int> error = Helpers.formatJsonAndEncodeUtf8(
    "ERROR 3623231 (Experiencebox could not be saved )", session: session);
    Future coucheFutureQuerySave = new Future(() {
      new Couchbase().couchConnExperiencebox.set(uniqueId, UTF8.encode(
          documentOriented.toString())).catchError((error) {
        print("COUCHEBASE ERROR 338420: " + error.toString());
        success = false;
      });
    }).catchError((error) {
      print("COUCHEBASE ERROR 338121: " + error.toString());
      success = false;
    });
    // Save data to MySql Database
    //create archiv entry
    Future <Results> mysql = mysqlCon.query(
        getQuery()).catchError((error) {
      print("failed archive");
      success = false;
    }).whenComplete((){
      print("completed archive");
      //querystring for insert word
      String wordQuery = new Tag().getInsertWordIfNotExists(tags);
      mysqlCon.query( wordQuery ).catchError((error) {
        print("failed word");
        success = false;
      }).whenComplete((){
        print("completed word");
        //query string for insert tags in blog
        String tagQuery = new Tag().getInsertTagsInBlogIfNotExists(tags, uniqueId);
        mysqlCon.query( tagQuery ).catchError((error) {
          print("failed tag in blog");
          success = false;
        });
      });
    });
    return Future.wait([mysql, coucheFutureQuerySave]).then((e) {
      // Save data to CoucheBase
      if (success) {
        print("completed all");
        return Helpers.formatJsonAndEncodeUtf8('OK', session: session, data:
            [new JsonObject.fromJsonString('{"id":"' + uniqueId + '"}')]);
      } else {
        print("failed");
        success = false;
      }
    });
}

运行它时，我得到了这个：

=== TO CLIENT ===
已完成存档
已完成全部
=== TO CLIENT ===
失败的
单词已完成 的单词
已完成 标记在博客中
完成投票

所以我的问题是，我怎么能等到未来的< code>mysql完成它的“childs”(在< code>whenCompleted()函数中)。我还尝试使用< code>then()而不是< code>whenCompleted(),但这并没有任何区别。

Answer 1

确保在异步函数中调用异步函数时总是返回未来值，以保持它们之间的连接。当您调用异步函数时，如

.then((x) => someAsync())

从< code>someAsync()返回的future是自动返回的，但是当您的代码具有类似

.then((x) {
  return someAsync()
 })

你需要显式返回。

有两行以

mysqlCon.query(

实际上应该是

return mysqlCon.query(

这条线

new Couchbase()

应该是可能是

return new Couchbase()

使用新的async/wait功能可以显着简化您的代码。