标签: dart-async

可以用Dart语言编写类似的代码吗？

int i;
try {
  i = await getResultAsync();
} catch(exception) {
  // Do something
}

Dart允许链接期货按顺序调用多个异步方法而不嵌套回调,这很棒.

假设我们想首先连接到像Redis这样的数据存储,然后运行一堆顺序读取:

  Future<String> FirstValue(String indexKey)
  { 
    return RedisClient.connect(Config.connectionStringRedis)
      .then((RedisClient redisClient) => redisClient.exists(indexKey))
      .then((bool exists) => !exists ? null : redisClient.smembers(indexKey))
      .then((Set<String> keys) => redisClient.get(keys.first))
      .then((String value) => "result: $value");
  }

四种异步方法,但代码相当容易阅读和理解.几乎看起来步骤是同步并按顺序执行的.美丽!(想象一下,必须使用嵌套的JavaScript回调编写相同的代码......)

不幸的是,这不会很有效:我们从.connect方法中获得的RedisClient 仅被分配给一个局部变量,该变量不在后续.thens的范围内.所以,redisClient.smembers和redisClient.get实际上将抛出一个空指针异常.

显而易见的解决方法是将返回值保存在具有函数范围的另一个变量中:

  Future<String> FirstValue(String indexKey)
  { 
    RedisClient redisClient = null;
    return RedisClient.connect(Config.connectionStringRedis)
      .then((RedisClient theRedisClient) 
          {
            redisClient = theRedisClient;
            return redisClient.exists(indexKey); 
          })
      .then((bool exists) => !exists ? null : redisClient.smembers(indexKey))
      .then((Set<String> keys) => redisClient.get(keys.first))
      .then((String …

Future readData() {
    var completer = new Completer();
    print("querying");
    pool.query('select p.id, p.name, p.age, t.name, t.species '
        'from people p '
        'left join pets t on t.owner_id = p.id').then((result) {
      print("got results");
      for (var row in result) {
        if (row[3] == null) {
          print("ID: ${row[0]}, Name: ${row[1]}, Age: ${row[2]}, No Pets");
        } else {
          print("ID: ${row[0]}, Name: ${row[1]}, Age: ${row[2]}, Pet Name: ${row[3]},     Pet Species ${row[4]}");
        }
      }
      completer.complete(null);
    });
    return completer.future;
  }

以上是从github SQLJocky Connector获取的示例代码

我想有人解释我如果可能的话,为什么是具有之外,那么pool.query被调用函数completer.complete(空)创建的完成者对象的功能.

总之,我无法理解打印执行后的部分.

注意:如果可能的话,我也想知道未来和Completer如何用于DB和非DB操作的实际用途.

我已经探讨了以下链接: …

我不理解该then()条款的语法.

1. myFuture(6).then( (erg) => print(erg) )

What's (erg) => expr语法？

我认为它可能是一个功能,但是

then( callHandler2(erg)

不起作用,错误:

"Multiple markers at this line
- The argument type 'void' cannot be assigned to the parameter type '(String) -> 
 dynamic'
- Undefined name 'erg'
- Expected to find ')'"

2. myFuture(5).then( (erg) { callHandler(erg);}, onError: (e) => print (e)

What´s `onError: (e) => expr"` syntactically?

3.变体onError:和.catchError(e)变体之间有区别吗？

是否可以设置测试可以运行的最长时间？就像：

@Test(timeout=1000)
public void testSomething() {}

在 jUnit 中？

我想从异步函数返回一个String,但我得到一个Future我做错了什么;

例

main() {
  String s;
  s = dummy("http://www.google.com");
}

String dummy(String s) {
  String response;
  response = readURL(s);
  return response;
}


Future<String> readURL(String requestString) async {
  String response = await http.read(requestString);
  print(response);
  return response;

}

错误:

type'_Future'不是'response'类型'String'的子类型.

更新（2020 年 7 月 15 日）

目前，mFeinstein 的回答是唯一给我第一个可接受的解决方案的答案。

void callWS() async {
    MyProgressDialog _dialog = DialogHelper.showMyProgressDialog(_context, "Data", "Loading...");
    await getDataFromService();
    _dialog.close();
  }

   static Future<void> getDataFromService() async {
    String uri = MY_URI;
    String wsMethod = MY_WS_METHOD;
    String wsContract = MY_WS_CONTRACT;

    SoapObject myRequest = SoapObject.fromSoapObject(namespace: my_namespace, name: wsMethod);

    MyConnectionResult response = await _openMyConnection(myRequest, uri, wsContract, wsMethod);
    if (response.result == MyResultEnum.OK) {
      await _parseResponse(response.data);
    }
  }

  static …