POC Node HTTP server for server-sent-events using RxJS