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