this._actions$
      .pipe(ofActionDispatched(ConnectWebSocket), takeUntil(this._destroy$))
      .subscribe(({ payload }) => {
        this.connect(payload);
      });