结合最新的正确语法

Question

我正在尝试使用combineLatest，特别是我需要将四个发出不同类型值的 Observable 与一个返回布尔类型的投影函数结合起来。

根据我从Rxjs documentation here 得到的信息，我认为这是我需要使用的combineLatest 签名，它没有被弃用：

combineLatest(sources: readonly any[], resultSelector: (...values: A) => R): Observable<R>

在我的情况下，R 是 boolean。

这是我尝试使用该函数的代码 sn-p，但 Visual Studio Code 显示带有删除线样式的调用，并且表明它已被弃用。

this.canBook$ = combineLatest(
                    this.userSvc.canRedirect(this.fbSvc.getUserId()),
                    this.userSvc.canBook(this.fbSvc.getUserId()),
                    this.calSvc.segnaleOrarioIso8601(),
                    this.selectedDay$,
                    (canredir: boolean, canbook: boolean, iso8601: string, selday: ICGiorno) => {
                      return canredir && (dayjs(selday.iso8601).diff(iso8601, 'hour') > 0) || 
                             canbook && (dayjs(selday.iso8601).diff(iso8601, 'hour') >= 24); 
                    } );

VS Code 说：

The signature '(v1: Observable<boolean>, v2: Observable<boolean>, v3: Observable<string>, v4: Subject<ICGiorno>, resultSelector: (v1: boolean, v2: boolean, v3: string, v4: ICGiorno) => boolean, scheduler?: SchedulerLike): Observable<...>' of 'combineLatest' is deprecated.ts(6387)

但是我没有传入任何调度程序参数，所以我不明白为什么 VS Code 将我的调用与不推荐使用的签名匹配，而不是上面 Rxjs API 文档中记录的签名。

你能帮我理解为什么吗？

Answer 1

正如 cmets 中所述，您使用的重载在 RxJS@6.6.7 combineLatest 中已弃用，没有 scheduler 就没有重载，但有一些带有 scheduler 的重载已被弃用，例如：

/** @deprecated resultSelector no longer supported, pipe to map instead */
export function combineLatest<O1 extends ObservableInput<any>, R>(sources: [O1], resultSelector: (v1: ObservedValueOf<O1>) => R, scheduler?: SchedulerLike): Observable<R>;
/** @deprecated resultSelector no longer supported, pipe to map instead */
export function combineLatest<O extends ObservableInput<any>, R>(sources: O[], resultSelector: (...args: ObservedValueOf<O>[]) => R, scheduler?: SchedulerLike): Observable<R>;

但是在RxJS@latest combineLatest 中，您可以找到您在问题中提到的重载，并且它没有被弃用，但您的代码中的问题是您使用的重载不是提到的重载，这也已被弃用：

/** @deprecated Pass an array of sources instead. The rest-parameters signature will be removed in v8. Details: https://rxjs.dev/deprecations/array-argument */
export function combineLatest<A extends readonly unknown[], R>(
  ...sourcesAndResultSelector: [...ObservableInputTuple<A>, (...values: A) => R]
): Observable<R>;

因此，要修复它，您只需使用您正确提到的重载（RxJS@latest 中未弃用），如下所示：

this.canBook$ = combineLatest(
  [ // <<<< The mentioned overload expects an array not Observables as params.
    this.userSvc.canRedirect(this.fbSvc.getUserId()),
    this.userSvc.canBook(this.fbSvc.getUserId()),
    this.calSvc.segnaleOrarioIso8601(),
    this.selectedDay$,
  ], // <<<<
  (
    canredir: boolean,
    canbook: boolean,
    iso8601: string,
    selday: ICGiorno
  ) => {
    return (
      (canredir && dayjs(selday.iso8601).diff(iso8601, 'hour') > 0) ||
      (canbook && dayjs(selday.iso8601).diff(iso8601, 'hour') >= 24)
    );
  }
);

Answer 2

我建议让运算符（如函数）做一件事来保持简单。无论 combineLatest() 中可能/可能不会弃用哪些功能，您都可以使用它来组合 observables。之后，您可以使用map() 运算符返回您的布尔值。

this.canBook$ = combineLatest([
  this.userSvc.canRedirect(this.fbSvc.getUserId()),
  this.userSvc.canBook(this.fbSvc.getUserId()),
  this.calSvc.segnaleOrarioIso8601(),
  this.selectedDay$,
]).pipe(
  map(
    ([canredir, canbook, iso8601, selday]) =>
      (canredir && dayjs(selday.iso8601).diff(iso8601, "hour") > 0) ||
      (canbook && dayjs(selday.iso8601).diff(iso8601, "hour") >= 24)
  )
);