When there is a fast producer and slow consumer, I want to replace all old waiting emissions with the newest one - something similar to RxJava's Emitter.BackpressureMode.LATEST
Is there any way to achieve this in RxDart or Dart Streams?
1 Answers
Hi it seems like I'm too late)
But maybe it will help someone else For back pressure in rxDart there is the Debounce method.
Example:
subject.debounce(new Duration(milliseconds: 500)).listen((s) => print(s));
More info:
Related