RxJS - 变换运算符 groupBy

在 groupBy 运算符中，输出基于特定条件进行分组，并且这些组项作为 GroupedObservable 发射。

语法

groupBy(keySelector_func: (value: T) => K):GroupedObservables

参数

keySelector_func − 给 source observable 中每个项指定键的函数。

返回值

返回值是 observable，它会以 GroupedObservables 形式发射值。

示例

import { of , from} from 'rxjs';
import { groupBy } from 'rxjs/operators';

const data = [
   {groupId: "QA", value: 1},
   {groupId: "Development", value: 3},
   {groupId: "QA", value: 5},
   {groupId: "Development", value: 6},
   {groupId: "QA", value: 2},
];

from(data).pipe(
   groupBy(item => item.groupId)
)
.subscribe(x => console.log(x));

如果你看到输出，它是一种 observable，其中项分组。我们给出的数据具有 QA 和开发两个组。输出显示了以下所示的相同分组 -

输出