RxJs WebSocketSubjectに接続した場合のイベントの取得

Question

WebSocketSubjectが接続されている場合、どのように応答することができますか？ソースコードで

（https://github.com/ReactiveX/rxjs/blob/master/src/observable/dom/WebSocketSubject.ts）彼らはタイプのopenObserverメンバーNextObserver<Event>

socket.onopen = (e: Event) => { 
 
     const openObserver = this.openObserver; 
 
     if (openObserver) { 
 
     openObserver.next(e); 
 
     } 
 
     .....

は、どのように私はソケットが開かれたことを、イベントを取得するには、それに接続することができますか？

let socket = new WebSocketSubject({ 
    url: 'ws://localhost:8081', 
    openObserver: { 
    next: value => { 
     console.log(value); 
    } 
    } 
}); 

それともNextObserverを拡張する独自のクラスを作成し、{ ..., openObserver: new MyObserver() }などのパラメータにそのインスタンスを渡すことができます。

Answer 1

openObserverパラメータを使用すると、使用することができますので、NextObserverインターフェースを受け付けます。