Я сейчас работаю над Angular App v7+
с Typescript v3.1.3
, используя RxJS v6.3.1
.Моя проблема в том, что я хочу вернуть ответвление с наблюдаемым массивом.
Вот так выглядит мой код:
getPlacesToShowForkJoin(location: GeoPoint, radius: number, dateRange: DateRange): Observable<Place[]> {
return this.getPlacesInRadius(location, radius).pipe(
switchMap( (places: GeoQueryDocument[]) => {
const availablePlaces = places.map( (place: GeoQueryDocument) => {
return this.getAvailablePlaces(dateRange, place.id).pipe(
map((bookings: Booking[]) => {
//removed code for better overview
return wantedObject;
}
})
);
});
return forkJoin(availablePlaces);
})
);
}
Я подписываюсь на getPlacesToShowForkJoin
, но это никогданазывается.Когда я консоль регистрирую availablePlaces
, я вижу массив, включающий 5 наблюдаемых.
Я что-то упустил или я что-то неправильно понял?