Привет, подскажите по rxjs. Есть сервис, который в конструкторе создает WS

Question

Привет, подскажите по rxjs. Есть сервис, который в конструкторе создает WS

Connection, в этом же сервисе есть вызовы для этого соединения.
пример:
sendMessage<T>(message: SignalMessage) {
return from(this.hubConnection.invoke<T>(message.name, ...message.args));
}
Проблема мне нужно отложить выполнение всех вызовов к WS пока соединение не будет установлено.

Для этого я сделал ReplaySubject который при успешном соединении сеттится в true,

private connected: ReplaySubject<boolean> = new ReplaySubject<boolean>(1);

Вопрос - как с помощью rxjs правильно отложить выполнение пока connected не эмитнул значение?

#javascript #programming #russian

0

09.01.2021

1 ответов

17 просмотров

ⓞⓝⓔⓜⓐⓝⓣⓞⓞ · Answer 1

ⓞⓝⓔⓜⓐⓝⓣⓞⓞ Автор вопроса

return this.connected.pipe( switchMap((rs) => { return from(this.hubConnection.invoke<T>(message.name, ...message.args)) }) ) Например насколько "правильный" такой вариант?

0

09.01.2021

169 похожих чатов

Привет, подскажите по rxjs. Есть сервис, который в конструкторе создает WS

1 ответов

Похожие вопросы