ws-11

gistfile1.ts

private connect(): void {
    this.websocket$ = new WebSocketSubject(this.config); // создаем

// если есть сообщения, шлем их в дальше,
// если нет, ожидаем
// реконнектимся, если получили ошибку
this.websocket$.subscribe(
    (message) => this.wsMessages$.next(message),
    (error: Event) => {
        if (!this.websocket$) {
            // run reconnect if errors
            this.reconnect();
        }
    });
}