Example of using Angular services and RxJS observables with a WebSockets Server - View it on GitHub