public onUserConnect = new Observable((observer) => {
    this.socket.on('connected_user', (val: any) => {
      observer.next(val);
    });
  });

  public onUserDisconnect = new Observable((observer) => {
    this.socket.on('disconnected_user', (val: any) => {
      observer.next(val);
    });
  });