RxJs Obesrver um websocket nur Feuer auf einen Teilnehmer gewickelt

Question

ich eine websocket in einem RxJS beobachtbar wie so bin Verpackung:

this.wsObserver = Observable.create(observer=>{ 
      this.websocket.onmessage = (evt) => { 
       console.info("ws.onmessage: " + evt); 
       observer.next(evt); 
      }; 
     }); 

Dies funktioniert, aber wenn ich mehrere Teilnehmer hinzufügen, nur ein Feuer (die letzte hinzugefügt):

this.wsObserver.subscribe((result) => { 
     console.info("! result: " + result); 
     }); 
     this.wsObserver.subscribe((result) => { 
     console.info("!2 result: " + result); 
     }); 

Nur !2 result: tritt auf.

Warum? Was mache ich falsch?

Answer 1

Das Problem besteht darin, dass Sie den Handler onmessage in Ihrem Erstellungshandler überschreiben, so dass nur der letzte Teilnehmer (der als letzter den Wert onmessage setzt) ​​aufgerufen wird.

Was könnten Sie tun, ist:

var var messageSubject = new Subject(); 
this.websocket.onmessage = (evt => messageSubject.next(evt)); 

und dann

messageSubject.subscribe(...) 

wird für so viele Teilnehmer arbeiten, wie Sie