icecream-data-dependencies-2.js

const filterLoggedIn$ = (stream$) => {
  return stream$.pipe(
    withLatestFrom(iceCreamAuth$),
    filter((auth) => auth)
  )
};

const combinedInfoFactory$ = (
  iceCreamPreferences$,
  iceCreamInventory$,
  iceCreamTemperature$
) => {
  return combineLatest(
    iceCreamPreferences$,
    iceCreamInventory$,
    iceCreamTemperature$,
  ).pipe(
    map(([iceCreamPreferences, iceCreamInventory, iceCreamTemperature]) => combineInfo(
      iceCreamPreferences,
      iceCreamInventory,
      iceCreamTemperature
    )),
  );
};

from(iceCreamIds).pipe(
  filterLoggedIn$,
  withLatestFrom(iceCreamVendor$),
  flatMap(([iceCreamId, iceCreamVendor]) => {
    if (iceCreamVendor) {
      return combinedInfoFactory$(
        iceCreamPreferences$,
        iceCreamInventory$,
        iceCreamTemperature$,
      ).pipe(
        map(([combinedInfo]) => [iceCreamId, combinedInfo]),
      );
    }
    return of([]);
  }),
  // ...
);