如何从带参数的函数返回combineLatest observable且避免重复创建？

你当前的写法每次调用fn()都会生成全新的combineLatest实例，每次订阅都会触发上游Observable重新执行，自然会产生大量重复的Observable实例，造成资源浪费。

确实可以将参数封装为可观察流，全局仅创建一次combineLatest实例，参数更新时直接推送新值即可满足需求，示例代码如下：

import { BehaviorSubject, combineLatest } from 'rxjs';
import { map } from 'rxjs/operators';

// 用BehaviorSubject承载参数，可保留最新的参数值
private argSubject = new BehaviorSubject<any>(null);
// 全局仅初始化一次combineLatest流
private result$ = combineLatest([
  yourFirstObservable$,
  yourSecondObservable$,
  this.argSubject
]).pipe(
  // 直接提取参数流的最新值返回
  map(([_, __, currentArg]) => currentArg)
);

// 更新参数的方法，参数变化时调用即可，不需要重建流
updateArg(arg: any) {
  this.argSubject.next(arg);
}

// 对外返回统一的结果流，全局仅一个实例
getResult$() {
  return this.result$;
}

该方案的优势：上游Observable仅会执行一次，不会产生重复实例，参数更新后流会自动输出对应结果，完全符合你预期的使用需求。

如果你需要保留fn(arg)的调用形式，也可以通过多播操作符共享上游流的执行结果，避免重复创建上游Observable：

import { combineLatest } from 'rxjs';
import { map, shareReplay } from 'rxjs/operators';

// 先对上游公共Observable做多播处理，所有订阅共享同一个执行结果
const sharedFirst$ = firstObservable$.pipe(shareReplay(1));
const sharedSecond$ = secondObservable$.pipe(shareReplay(1));

fn(arg) {
  return combineLatest([
    sharedFirst$,
    sharedSecond$
  ]).pipe(
    map(() => arg),
    // 可选：相同参数调用的返回流也做多播，进一步减少重复实例
    shareReplay(1)
  );
}

该方案适用于参数调用频率低、不同参数需要返回独立流的场景。

• 使用方案1时，不需要使用流后记得调用argSubject.complete()销毁资源，避免内存泄漏
• shareReplay的缓冲区大小可根据业务需求调整，不需要保留历史值的场景可以替换为share()操作符

内容的提问来源于stack exchange，提问作者Unknown