Rx js websockets в проекте angular

Question

let observable = Rx.Observable.create ((obs: Rx.Observer) => {

  this.ws.onmessage = obs.next.bind(obs);
  this.ws.onerror = obs.error.bind(obs);
  this.ws.onclose = obs.complete.bind(obs);

  return this.ws.close.bind(this.ws);
});

Я новичок в машинописи / angular и видел это во многих учебниках по веб-сокетам, но Я не совсем понимаю, что происходит. Из того, что я могу собрать, первая часть связывает методы наблюдателя с контекстом наблюдателя с методами веб-сокета. Это имеет смысл для меня, но я просто не могу понять, для чего возврат. Спасибо заранее и извините, если это кажется немым.

Answer 1

1. Observable.create устарело. Для этого используйте new Observable.
2. Я бы не советовал создавать Наблюдательный WebSocket самостоятельно, поскольку Rx JS уже предоставляет его. Документация к этому могла бы быть лучше, но здесь вы go: https://rxjs.dev/api/webSocket/webSocket Был также довольно хороший разговор об этой топике c в прошлом году на NgSpain: https://www.youtube.com/watch?v=BEHDkAFTnzU