jeffbcross / aim

82 stars 27 forks source link

feat(RxWebSocket): add a primitive web socket service #8

Closed benlesh closed 8 years ago

benlesh commented 8 years ago

The interface is basically:

var socket = new RxWebSocket(someUrl);

socket.out.subscribe(msg => doStuff(msg));

someObservable.subscribe(socket.in);