飞镖流可以保存数据

Question

我不清楚Dart中的单个订阅者流是否真的保存了他们收到的数据。如果他们这样做，有没有办法禁用它，因为这似乎是一次重大内存泄漏？

使用 Dart 中的新async*功能，这些流是否存储数据？

Answer 1

StreamController 构造函数上的代码文档说

• 控制器将缓冲所有传入事件，直到订阅者
• 注册。

若要避免排队事件，可以使用广播流

new StreamController.broadcast(...);

或暂停订阅

StreamSubscription sub;
sub = s.listen((e) {
  sub.pause();
  // process event
  sub.resume();
});

由async*创建的流的行为相同

import 'dart:async';
Stream<int> a() async* {
  for (int i = 1; i <= 10; ++i) {
    print('yield $i');
    yield i;
  }
}
main() {
  a().listen((e) async {
    await new Future.delayed(const Duration(seconds: 1));
    print(e);
  });
  StreamSubscription sub;
  sub = a().listen((e) async {
    sub.pause();
    await new Future.delayed(const Duration(seconds: 1));
    print(e);
    sub.resume();
  });
}

在DartPad尝试

第一个示例打印

yield 1
yield 2
yield 3
yield 4
yield 5
yield 6
yield 7
yield 8
yield 9
yield 10
1
2
3
4
5
6
7
8
9
10

第二个示例(带pause(打印

yield 1
yield 2
yield 3
1
2
yield 4
3
yield 5
4
yield 6
5
yield 7
6
yield 8
7
yield 9
8
yield 10
9
10

Answer 2

我假设您在引用单个订阅者流时的意思是Future。

据我了解，新关键字不会改变实际行为。async/async*将分别创建一个Future/Stream，该将自然缓冲数据，直到它们实际交付。例如，您可以同时执行以下两项操作：

import 'dart:async';
Future single() async {
  return 42; 
}
main() async {
  int r = await single();
  print('ok: $r');
  single().then((int val) {
    print('val $val');
  });
}

所以最后我会说他们的行为是一样的，你只是用不同的方式表达你正在做的事情。因此，仅当有侦听器时，流才会获取数据。然后数据将照常交付。

他们网站上的一句话：可以使用 Stream 和相关类手动实现流。异步生成器函数是实现此类流的糖