rxjs-take-while-inclusive