Refactored observable using async/mult