Hands-On Reactive Programming with Python

Custom disposal

When the create factory operator is used, it is possible to provide a custom disposal function. This function will be called when the dispose method of the disposable object returned by the subscription is called. Consider the following example, similar to the previous one, but with the observable being a custom one:

def on_subscribe(observer):    def dispose():        print("disposing custom observable")            observer.on_next(1)    observer.on_next(2)    observer.on_next(3)     observer.on_completed()    return disposenumbers = Observable.create(on_subscribe)subscription = numbers.subscribe(    on_next = lambda i: print("on_next {}".format(i)),    on_error = lambda e: print("on_error: {}".format(e)),    on_completed = lambda: print("on_completed"))subscription.dispose() ...