如何在飞镖流上设置背压。 （或rxdart）

Question

有没有办法设置飞镖流的背压？

我想实现这样的功能：

1. 用户按下按钮。
2. 将数据添加到 PublishSubject。
3. 即使在处理添加的数据时添加了其他数据，也会被忽略。

我不知道该怎么做。

有什么好办法吗？

Answer 1

DART流具有内置的背压（缓冲）。

Stream.periodic(const Duration(milliseconds: 100), (i) => i)
  .take(5)
  .listen((v) async {
    await Future<void>.delayed(const Duration(milliseconds: 500));
    print(v);
  });

await Future<void>.delayed(const Duration(seconds: 10));

// will print 0, 1, 2, 3, 4

您可以使用dyailmap rxdart忽略/删除值。

Stream.periodic(const Duration(milliseconds: 100), (i) => i)
  .take(5)
  .exhaustMap((v) => Rx.timer(v, const Duration(milliseconds: 500)))
  .listen(print);

await Future<void>.delayed(const Duration(seconds: 10));

// will print 0