search

ReactiveX / RxPY

ReactiveX for Python
https://rxpy.rtfd.io
MIT License
4.78k stars 362 forks source link

RxPy and backpressure dropping #261

Closed tadas-subonis closed 5 years ago

tadas-subonis commented 5 years ago

Hi all,

is it possible to create a backpressured Obserable that would drop the items, that the downstream cannot process?

Tadas

dbrattli commented 5 years ago

Closing this as backpressure now have been removed from the code base.

tadas-subonis commented 5 years ago

@dbrattli What's the available alternative?

dbrattli commented 5 years ago

In the new code-base the operators are not stitched into the Observable class, thus you can use any function Callable[[Observable], Observable] as an operator. So you could implement operators yourself, or use other library that would implement functionality like back-pressure. Taking the back-pressure code into it's own library and caring for it is up-for-grabs. It will just not be part of the main library anymore. RxPY was getting too large and it was getting impossible to maintain. The need for back-pressure is also a sign that you should use (Async)Iterables instead of Observables. Thus it doesn't really belong in RxPY.

tadas-subonis commented 5 years ago

Thanks. I like the point about using (async) pull-based options.

On Tue, Jan 22, 2019 at 2:28 PM Dag Brattli notifications@github.com wrote:

In the new code-base the operators are not stitched into the Observable class, thus you can use any function Callable[[Observable], Observable] as an operator. So you could implement operators yourself, or use other library that would implement functionality like back-pressure. Taking the back-pressure code into it's own library and caring for it is up-for-grabs. It will just not be part of the main library anymore. RxPY was getting too large and it was getting impossible to maintain. The need for back-pressure is also a sign that you should use (Async)Iterables instead of Observables. Thus it doesn't really belong in RxPY.

— You are receiving this because you authored the thread. Reply to this email directly, view it on GitHub https://github.com/ReactiveX/RxPY/issues/261#issuecomment-456399084, or mute the thread https://github.com/notifications/unsubscribe-auth/AAPFsvzY_8DdcuPASYsK6N2IjvQyIXGHks5vFxIagaJpZM4YMKmZ .

--

Kind Regards, Tadas Šubonis

lock[bot] commented 4 years ago

This thread has been automatically locked since there has not been any recent activity after it was closed. Please open a new issue for related bugs.