在 Dart 中，为什么要等待一个微不足道的（“空”）StreamController 流立即退出程序？

Question

这是一个简单程序的主干，它使用 StreamController 监听某些输入流并在其自己的流上输出一些其他数据作为响应：

import 'dart:async';     

main() async {     
    var c = StreamController(         
            onListen: (){},         
            onPause: (){},         
            onResume: (){},         
            onCancel: (){});         

    print("start");         
    await for (var data in c.stream) {         
            print("loop");         
    }         

    print("after loop");         
}     

输出：

$ dart cont.dart
start
$ dart

为什么这段代码在没有执行 print("loop") 和 print("after loop") 的情况下直接在 await for 行退出？

注意：在原始程序中，onListen() 将接收输入流并订阅它。循环实际上一直在工作，直到在输入流上调用 subscription.cancel()，当它也突然退出时，没有任何机会清理。

Answer 1

我对此感到惊讶，但是所有async/await 代码再次转换为.then()s，似乎所有内容都无法完美翻译。

这似乎是答案的一部分：您需要在另一个任务中关闭流才能离开await for。 Here 是以前的相关问题。由于我们不关闭它，await for 之后的行不会执行。这是一个避免这种情况的示例：

import 'dart:async';

main() async {
  var c = StreamController(
      onListen: () {},
      onPause: () {},
      onResume: () {},
      onCancel: () {});

  print("start");
  await Future.wait(<Future>[producer(c), consumer(c)]);

  print("after loop");
}

Future producer(StreamController c) async {
  // this makes it print "loop" as well
  // c.add("val!"); 
  await c.close();
}

Future consumer(StreamController c) async {
  await for (var data in c.stream) {
    print("loop");
  }
}

哪个打印：

start
after loop

所以，故事的寓意是，

1. 永远不要让 StreamController 无人看管，否则会发生奇怪的事情。
2. 您等待的一些异步函数会破坏您的代码，甚至绕过您的 try/finally 块！

我以为我对 async/await 了如指掌，但第二点现在让我害怕了。