使用 of() 创建的 Observable 会立即完成，导致订阅关闭，无法响应后续数据变化；正确做法是通过 MatTableDataSource.connect() 获取持续发射数据的 Observable，并结合 async 管道实现响应式更新。
使用 `of()` 创建的 observable 会立即完成，导致订阅关闭，无法响应后续数据变化；正确做法是通过 `mattabledatasource.connect()` 获取持续发射数据的 observable，并结合 `async` 管道实现响应式更新。
在 Angular 中，MatTableDataSource 并非普通的 Observable，而是一个可观察的数据容器——它内部维护着一个 Subject，并通过 connect() 方法暴露一个持续发射当前数据的 Observable<T[]>。这正是实现「下拉选项随表格数据动态更新」的关键。
你原先使用 of(this.tableDataSource.data) 的问题在于：of() 仅将当前快照值（即初始化时的空数组或初始数据）作为单次事件发出，随后立即完成（completed），因此订阅自动关闭，后续调用 this.tableDataSource.data = newData 不会触发任何通知。
✅ 正确方案是利用 dataSource.connect()：
// 组件类中定义
tableDataSource: MatTableDataSource<RandomInterface> = new MatTableDataSource<RandomInterface>();
dropdownMultipleUniqueOptions$: Observable<string[]>;
ngOnInit() {
this.dropdownMultipleUniqueOptions$ = this.tableDataSource.connect().pipe(
map(data => data.map(item => item.param3)), // 提取 param3 字段
map(values => [...new Set(values)]), // 去重（比 indexOf 更高效）
shareReplay({ bufferSize: 1, refCount: true }) // 可选：避免重复计算，支持多订阅
);
}模板中配合 async 管道使用（无需手动订阅/销毁）：
<mat-select
class="filterMultiselect"
formControlName="filterParam3"
multiple
panelClass="filterMultiselect"
placeholder="Filter"
(selectionChange)="updateManualPage(1)">
<mat-option *ngFor="let option of dropdownMultipleUniqueOptions$ | async" [value]="option">
{{ option }}
</mat-option>
</mat-select>⚠️ 注意事项：
- connect() 返回的 Observable 在 MatTableDataSource 被销毁（如组件 ngOnDestroy）时不会自动取消订阅，但因 async 管道已内置生命周期管理，此处无需额外 takeUntil；
- 若需在组件中多次使用该流（如同时用于搜索 + 下拉），建议添加 shareReplay(1) 避免重复执行去重逻辑；
- 确保 tableDataSource.data 的更新方式正确：直接赋值（dataSource.data = newData）或调用 dataSource._updateChangeSubscription()（不推荐），前者即可触发 connect() 流重发；
- MatTableDataSource 的 connect() 在 Angular Material v15+ 中仍为公开 API，官方文档明确支持（见 Material Table DataSource）。
这样，每当调用 this.tableDataSource.data = updatedData 或 this.tableDataSource.renderRows() 时，dropdownMultipleUniqueOptions$ 都会重新计算并推送最新唯一值列表，真正实现响应式联动。
