Using RxJS to manage user input