rxPY3: Always implement on_error and on_completed


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:

  1. I had forgotten to call on_completed()
  2. 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.


See also