Совместное использование Auth Наблюдаемое значение между компонентами без его выполнения несколько раз

Question

У меня есть AuthService, который извлекает данные Observable<auth> из Firebase и помещает их в общедоступную переменную auth$.

Где-то в моем приложении мне нужно несколько компонентов для доступа к этому значению auth$, чтобы проверить его содержимое.

Я сейчас просто делаю this.authService.auth$.subscribe(auth => this.auth = auth) в компонентах.

1. Означает ли это, что я выполнение fetch data from Firebase несколько раз?

2. Если да, то я должен определить аутентификации $ как субъект/BehaviorSubject, подписаться на услугу и передавать данные с .next?

Answer 1

По умолчанию наблюдаемый не включен многоадресной рассылкой. Это означает, что несколько подписей будут генерировать собственный поток. Поскольку вы не хотите повторно запрашивать учетные данные для аутентификации на подписку, вам необходимо сделать свой мультикаст с исходным потоком. Это делается с использованием, например, оператора share(), который сделает поток горячим по первой подписке и внутренне сохранит refcount для всех следующих подписчиков.

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

Оба эти требования объединены в операторе shareReplay(), который позволяет использовать многоадресную рассылку последних значений n.

Так что ваш код будет выглядеть следующим образом:

const authStream = this.authService.auth$.shareReplay(1); 

// component 1 
const myAuthDisposable = authStream.subscribe(auth => this.auth = auth) 

// component 2 
const myAuthDisposable = authStream.subscribe(auth => this.auth = auth)