Snippet for integrating websockets using rxjs. Below code is using an integration example for angular

websocket-base.service.ts

import { Injectable } from '@angular/core';
import {WebSocketSubject, webSocket} from 'rxjs/webSocket'

@Injectable({providedIn: 'root'})

export class WebsocketBaseService {

  private serverMessages : Array<any>
  private socket$: WebSocketSubject<any>;
  private  readonly socketURL = "url"

  constructor() { 
    this.socket$ = webSocket(this.socketURL);
    this.connect();
  }
      
  connect(){
    this.socket$
    .subscribe(
    (message) => {
      this.serverMessages.push(message);
    },
    err =>{
         // "Could not connect to socekts server",
    } ,
    () => console.log('Completed!')
    );
  }
      

  /**
   * @description multiplex multiple messages over the same channel
   * @param type unique message indentifier, may be api name
   * @param message information to send to backend is an JSON Object
   * @returns an Observable, subscribe to catch server message
   * @reference https://rxjs-dev.firebaseapp.com/api/webSocket/webSocket
   */
  multiplexSend( type : string, message: any ){
    return this.socket$.multiplex(
      () => message,
      () => JSON.stringify({"unsubscribe" : type}),
      message => message.Operation == type
    )
  }

}