Как мне заставить switchMap запускаться внутри комбайна? - PullRequest
0 голосов
/ 28 июня 2018

У меня есть следующий код, и он не запускает switchMap. Не уверен, что я делаю не так.

import { switchMap} from "rxjs/operators";
import { combineLatest } from 'rxjs';

this.companies$ = combineLatest(this.authService.user$, this.filter$ ).pipe(
            switchMap(([user, filter]) =>{
                return this.afs.collection<CompanyProfile>('companies', ref => {
                console.log("this doesnt fire"); 
                if (user) { ref.where('owner.network', '==', user.activeNetworkProfile.id) };
                if (filter) { ref.where('name', '==', filter) };
                return ref;
                }).valueChanges();
            } 
        ));

1 Ответ

0 голосов
/ 28 июня 2018

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

this.filter$ = new BehaviorSubject(null); 
...