@extensionmethod(Observable, alias="then")
def then_do(self, selector):

    return Pattern([self]).then_do(selector)
Matches when the observable sequence has an available value and projects
dataset/ETHPy150Open ReactiveX/RxPY/rx/linq/observable/thendo.py/then_do