Websocket RxJs

by Leo

HTML

<script src="//unpkg.com/@reactivex/[email protected]/dist/global/rxjs.umd.js"></script>

JavaScript

debugger;
var ws = new rxjs.webSocket.webSocket('ws://echo.websocket.org')/*.destination*/.share();
 
var aSunscription = ws.subscribe(msg => console.log("receive by A", msg));
var bSunscription = ws.subscribe(msg => console.log("receive by B", msg));
console.log("send");
ws.next(JSON.stringify({message: 'some message'}));


///* 
setTimeout(()=>{
  aSunscription.complete();
  bSunscription.complete();

  ////////////////////////////////////////////////////////////////////////////////
  console.log("send");
  aSunscription = ws.subscribe(msg => console.log("receive by A(new)", msg));
  bSunscription = ws.subscribe(msg => console.log("receive by B(new)", msg));

  ws.next(JSON.stringify({message: 'another some message'}));
}, 5000);
 //*/