task1

from rx import Observable

source = Observable.from_([1 ,1 ,1 ,0 ,0 ,2 ,2 ,3]) \
                   .scan(lambda t, i: max(t, i))\
                   .group_by(lambda i: i)\
                   .map(lambda i: 1)\
                   .reduce(lambda t, i: t+1)\
                   .subscribe (lambda value : print(value-1));