search

ReactiveX / rxdart

The Reactive Extensions for Dart
http://reactivex.io
Apache License 2.0
3.36k stars 271 forks source link

How to use backpressure? #668

Closed dylan-kwon closed 2 years ago

dylan-kwon commented 2 years ago

Are there backpressure operators like in Rx in other languages?

I want to implement a function like this:

  1. The user presses a button.
  2. Add data to PublishSubject.
  3. Even if other data is added while the added data is being processed, it is ignored.

I don't know how to this it.

Any good way?