Я работал над приложением на основе Angular, которое в значительной степени зависит от RxJS Subjects и Observables.
Я столкнулся со странной ситуацией, когда оно появляется , которое мне нужно вызвать следующим () для субъекта, а затем приостановите выполнение до тех пор, пока все подписчики не выполнят или не завершат свою работу.
Вот несколько простых псевдокодов, иллюстрирующих ситуацию:
this.resetFilterSubject.next();
// Must wait until the subscribers have acted before loading new items this.loadSpecificItemsOnTheTree();
Мой вопрос:
- Как мне ждать / получить обратный вызов, когда все подписчики закончили (если это вообще возможно)?
- Является ли это распространенным сценарием при работе с Observables в RxJS / Angular, или это просто плохой дизайн?