Might be missing something, but how is this related? Is the assumption that this is what RxJS gives you? Because I mean...that's a websocket. And how you model the event, and handle it...is up to you. Don't need any library to help you unless you want one.