rx
rx copied to clipboard
Observable pipeline question
How can I create an observable pipeline that runs continuously. It'll wait for input, process it and keep running. Wait for another input, process and keep waiting until and tell it to stop? Can figure the API