Как убедиться что ассинхронная инициализация в конструкторе сервиса Angular завершена?

Question

[godyear]

Знатоки, подскажите пожалуйста, как убедиться, что асинхронная инициализация в конструкторе сервиса завершенна при вызове других функций в классе?

Пример кода:

constructor() {
    var sock = new SockJS(this._chatUrl);
    this.stompClient = Stomp.over(sock);
    this.stompClient.connect({}, function () {
    });
  }

  public subscribe(topicName: string, messageReceived) {
    this.stompClient.subscribe('/topic/' + topicName, function (message) {
      messageReceived(message);
    })
  }

  public sendMessage(msgDestId: string, message) {
    this.stompClient.send("/app/" + msgDestId, {}, JSON.stringify(message));
  }

Как видите, в конструкторе устанавливается соединение с stomp-сервером. После чего, клиентам (компонентам) этого сервиса предлагается подписаться на интересующие топики. Естественно, что вызов функции subscribe не имеет смысла пока соединение полностью не установленно.

Answer 1

[Negwereth]

Конструктор не должен быть асинхронным. Проводите инициализацию отдельным методом, на который уже давайте возможность подписаться.

Comments

[godyear]

Этот сервис инжектится в множество компонентов. Они не могут самостоятельно вызывать .connect функцию т.к. в таком случае они будут пытаться установить соединение одновременно.
Мне нужно, что бы все компоненты общались через одно соединенение.

[Negwereth]

godyear: и в чём проблема? При вызове connect проверять, инициализирован ли сервис или нет? Он же синглтон и так.

[godyear]

Чем это принципиально будет отличаться от такого-же механизма проверки в конструкторе? Например через переменную класса? Можно ли расчитывать, что оба компонента будут обращаться к функции connect синхронно?

Мне бы хотелось избежать ситуации, когда мне нужно делать .connect в каждой функции класса. Т.к. вся остальная функциональность зависит от .connect.

Answer 2

[Aleksei Podgaev]

1. Как правильно заметили в предыдущем ответе - конструктор не должен быть асинхронным. Вынесите инициализацию в отдельный метод.

2. Почему нельзя подписывать до установления соединения? Кто это сказал? Я не знаю, насчёт используемого вами клиента, но можно же свой Subject (из RxJs) объявить, на него подписаться, а он уже будет прокидывать события из сокета, когда соединение установится. Т.е. на события сокета подписывается только сервис, который его создал, после того, как соединение будет установлено. Все остальные подписываются на события этого сервиса. Сервис пробрасывает все события, которые приходят от сокета, своим подписчикам.

Comments

[godyear]

Я все-равно не до конца понимаю, как конкретно я могу убедится что соединение установлено? Через глобальную переменнеую класса isConnected? Если да, то как организовать задержку, если isConnected = false?

[godyear]

Если бы Вы так же могли предложить пример кода, который вы имеете ввиду, было бы замечательно!