web-socket.service.ts

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

@Injectable()
export class WebSocketService {

  private _ws: WebSocketSubject<string>;

  constructor() { }

  connect() {
    const webSocketUrl = 'ws://localhost:9000'
    this._ws = new WebSocketSubject(webSocketUrl);
    this._ws.subscribe((data: string) => {
      console.log('Data: ', data);
    });
  }
  
   sendMessage() {
    this._ws.next({type: MessageTypeEnum.ConsoleError, data: null});
  }


}