angular - Websocket onmessage事件仅触发一次

我在Angular6应用程序中使用一个基本的WebSocket客户端。
一切正常工作，除了某些原因，socket.onmessage或socket.addEventListener('message'都只被触发一次。控制台上没有错误。消息被明确地发送到客户端（正确的消息显示在浏览器控制台的websocket连接框架中）。所有其他事件都正常工作。
以下是我的课程，学习websockets：

export class WebsocketService  implements OnDestroy {
  socket: WebSocket;

  constructor(@Inject(APP_CONFIG) private config: IAppConfig, private authService: AuthService) { }

  initConnection(): void {
    this.socket = new WebSocket(
      this.config.apiEndpoint.replace(/^https?:\/\//i, 'ws://') + 'ws/');
    this.watchEvent(WSEvent.ERROR).subscribe(data => {
      console.log(data);
    });
  }

  watchEvent(wsevent: WSEvent): Observable<any> {
    return new Observable(observer => {
      this.socket.addEventListener(wsevent, function (event) {
        observer.next(event);
      });
    });
  }

  onMessage(): Observable<any> {
    return new Observable(observer => {
      this.socket.onmessage = function (event) {
        observer.next(event);
      };
    });
  }

  ngOnDestroy() {
    // this.socket.close();
  }
}

wsevent:事件：

export enum WSEvent {
  CLOSE = 'close',
  OPEN = 'open',
  MESSAGE = 'message',
  ERROR = 'error'
}

用法：

this.wsService.watchEvent('message').subscribe((data) => {
   console.log(data);
});


this.wsService.onMessage().subscribe((data) => {
  console.log(data);
});

在这两种情况下，console.log(data);只显示发送给客户端的第一条消息。消息发送多少次并不重要，消息的内容--cc>（引用两个选项）只被触发一次。
更新：
更新了这篇文章以包含实际的工作解决方案（问题是我在onmessage之后立即调用了observer.complete();，它完成了它应该做的事情）

最佳答案

必须从观察者中移除observer.complete();。