使用 await for 流和处理 done + onError 回调

Question

我正在使用dart:io的HTTP客户端下载大文件，方式如下：

final url = Uri.parse(fileUrl);
final request = await httpClient.getUrl(url);
final response = await request.close();

然后我使用HttpClientResponse 类型的response 实现Stream<List<int>>，其中每个发出的List<int> 代表正在下载的文件块。

我的目标是将该流“转换”为另一个流，为此，我最近了解到await for + yield 可以做到这一点：

Stream<Event> processResponse(HttpClientResponse response) async* {
    await for (final List<int> chunk in response) {
        yield Event.FileChunk(chunk: chunk);
    }
    yield const Event.Completed();
}

最初，在了解await for之前，我打算使用Stream<T>.listen方法，它接受4个参数：

1. onData 回调用于流中每个发出的值，
2. onError 回调，用于在发出值时通知错误，
3. 通知流的onDone 回调正在关闭并且不会发出任何新值，最后
4. cancelOnError 自解释的布尔参数。

通过使用await for () {}，我相信我涵盖了#1 和#3，因为我将获得所有发出的值，完成后，代码将离开await for 的范围，这应该意味着它已经完成。

但是错误呢？由于这些流将是冗长且繁重的 IO 流，因此肯定随时可能出现 IO 错误。他们是如何报道的？我如何访问他们的数据以报告这些数据并在需要时进行调试？

Answer 1

只需使用好的 ol' try catch，请参阅这个简化的示例：

Stream<int> inee()async*{
  try{
    for (int i = 0; i <= 5; i++) {
      if(i==4)throw Exception('Hated number 4');
   yield i;
  }
  
  }catch(e,st){
    print('Catch exception $e');
    yield 33;
  }  finally{
    //cleanup of incomplete files
  }
}
void main() {
inee().listen(print);
}

输出如下：

0
1
2
3
Catch exception Exception: Hated number 4
3

在你仍然可以让出的 catch 中，记录你的异常。您还可以将删除不完整文件的逻辑添加到 finally 块中。