Поддерживает ли RxDart противодавление?

Question

Когда есть быстрый производитель и медленный потребитель, я хочу заменить все старые ожидающие выбросы на новейшие - что-то похожее на Emitter.BackpressureMode.LATEST RxJava.

Есть ли способ добиться этого в RxDart или Dart Streams?

Answer 1

Привет вроде как я опоздала)

Но, возможно, это поможет кому-то другому. Для обратного давления в rxDart есть метод Debounce.

Пример:

subject.debounce(new Duration(milliseconds: 500)).listen((s) => print(s));

Больше информации:

https://www.youtube.com/watch?v=u9VgxH-X_7s