4 ms·
That information is a bit dated as we have several ways of dealing with backpressure starting with RxJS 2.2.15 with the inclusion of pausable/pausableBuffered a
by mattpodwysocki 12y ago
That information is a bit dated as we have several ways of dealing with backpressure starting with RxJS 2.2.15 with the inclusion of pausable/pausableBuffered and controlled https://github.com/Reactive-Extensions/RxJS/releases/tag/v2.2.15 https://github.com/Reactive-Extensions/RxJS/releases/tag/v2....
We then updated it to have .pause and .resume methods on the Observable itself to take care of some of the ugliness:
https://github.com/Reactive-Extensions/RxJS/releases/tag/v2.2.19 https://github.com/Reactive-Extensions/RxJS/releases/tag/v2....
Overall, these do not go ultimately up to the publisher as we're dealing with multicast streams in which we don't want other subscribers to pay any penalty for one slow subscriber.
- platz 12y agointeresting, thanks!