Functional Reactive Wrapper for a Primus.io Client