In my quest to better understand rxPY
, I have written some short example scripts that use different operators. I have published these on GitHub as rxpy3-examples. In order to keep the examples as short as possible, I had omitted implementing on_error
and on_completed
. I thought that simple examples would be bloated by this, but that was actually a mistake.
When I implemented these calls, I noticed that I had made a couple of mistakes in my previous implementation of the custom observable called dequeue
:
- I had forgotten to call on_completed()
- I had forgotten to return a
Dispoble
Not a big deal in an example, but probably not so good in production. The examples have been updated.
If you liked this post, please, do share it:
Thanks, for reading (and sharing)! 🥳