julienpradet / blog-posts Goto Github PK

 let subject = Observable.webSocket('ws://localhost:8081');
 subject.subscribe(
    (msg) => console.log('message received: ' + msg),
    (err) => console.log(err),
    () => console.log('complete')
  );
// Reconnexion automatique, voire aussi avec 'retryWhen'
subject.retry().subscribe(...);
// Envoi de message
subject.next(JSON.stringify({ op: 'hello' }));