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_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
- I had forgotten to call on_completed()
- I had forgotten to return a
Not a big deal in an example, but probably not so good in production. The examples have been updated.