是否有ESLint规则可检测Observable遗漏subscribe()调用？

1. TypeScript 类型约束方案 #

通过自定义类型强制要求Observable必须被订阅，直接丢弃返回值会触发类型错误。

import { Observable } from 'rxjs';

// 自定义类型，重载subscribe方法，确保调用后才完成合法操作
type MustSubscribeObservable<T> = Observable<T> & {
  subscribe(): void;
  subscribe(next: (value: T) => void): void;
  subscribe(next: (value: T) => void, error: (error: any) => void): void;
  subscribe(next: (value: T) => void, error: (error: any) => void, complete: () => void): void;
};

function deleteIt(): MustSubscribeObservable<any> {
  return httpService.delete('/foo') as MustSubscribeObservable<any>;
}

deleteIt(); // TypeScript 直接报错，提示表达式不可调用或必须调用subscribe
deleteIt().subscribe(); // 合法操作，无错误

2. ESLint 规则检测 #

使用RxJS官方ESLint插件的rxjs/no-ignored-observable规则，静态检测未被订阅/转换的Observable。

• 安装依赖：

npm install eslint-plugin-rxjs --save-dev

• 在ESLint配置文件中启用规则：

{
  "plugins": ["rxjs"],
  "rules": {
    "rxjs/no-ignored-observable": "warn" // 设为error直接阻断编译，warn仅提示
  }
}

配置后，直接调用返回Observable的函数却不处理时，ESLint会给出明确警告。

3. 运行时调试提示 #

针对开发阶段，可以包装Observable，在未被订阅时打印警告和调用栈，快速定位问题。

import { Observable } from 'rxjs';

function trackUnsubscribed<T>(obs: Observable<T>): Observable<T> {
  let isSubscribed = false;
  // 延迟检查，避免异步订阅的误判
  setTimeout(() => {
    if (!isSubscribed) {
      console.warn('⚠️ 发现未被订阅的Observable，该操作可能无效');
      console.trace(); // 打印调用栈，方便定位代码位置
    }
  }, 150);

  return new Observable<T>(subscriber => {
    isSubscribed = true;
    const sub = obs.subscribe(subscriber);
    return () => sub.unsubscribe();
  });
}

// 在业务函数中使用包装后的Observable
function deleteIt(): Observable<any> {
  return trackUnsubscribed(httpService.delete('/foo'));
}

deleteIt(); // 150ms后控制台输出警告及调用栈
deleteIt().subscribe(); // 正常订阅，无警告

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