Dart:在给定时间后停止收听流

Question

我有一个Dart服务器，它从iccast流中获取元数据。

获取元数据，我有以下方法:

void getMetaData() {
    HttpClient client = new HttpClient();
    client.getUrl(Uri.parse(this.src))
    .then((HttpClientRequest request) {
        request.headers.add(HttpHeaders.USER_AGENT, "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/27.0.1453.110 Safari/537.36");
        request.headers.add("Icy-MetaData", "1");
        return request.close();
    })
    .then((HttpClientResponse response) {
        if(response.headers.value("icy-metaint") != null) {
            this.offset = int.parse(response.headers.value("icy-metaint"));
            //print(response.headers.toString());
            bool stop = false;
            List<int> metaData = new List();
            streamListener = response.listen(null);
            streamListener.onData((data) {
                while(!stop) {
                    if(data.length > 17000) { stop = true; }
                }
                metaData = data.getRange(offset, offset + data[offset]*16);
                String metaDataString = new String.fromCharCodes(metaData);
                print(metaDataString);
                streamListener.cancel();
            });
            streamListener.onError((e) {
                print(e);
            });
        }
    });
}

该方法按预期工作，直到流没有返回任何数据或返回数据的时间过长。然后它就停止工作了。我假定该方法不会退出while循环。

这就是为什么我可能需要另一个条件来打破while循环。我认为一个计时器会很好，但我不知道如何实现一个计时器来打破while lopp后5秒左右。或者是否有更好的方法来获取数据。

Answer 1

DateTime endTime = new DateTime.now().add(new Duration(milliseconds: 5000));
while(!stop) {
  if(data.length > 17000 || new DateTime.now().compareTo(endTime) > 0) {
    stop = true;
  }
}

但是你最好找到一种方法来实现这个，而不需要这个忙循环