如何使用RxJS将单数组按每2个元素拆分为多子数组？

嘿，这需求其实挺常见的，咱们直接上实用方案就行。因为你的服务是一次性返回整个数组作为Observable的单次发射值，所以只需要在pipe()里用map操作符转换这个数组，就能把它拆成每2个元素一组的子数组。

方案1：原生JavaScript实现（无外部依赖） #

自己写个简单的分块逻辑，完全可控，不用额外装库：

import { of } from 'rxjs';
import { map } from 'rxjs/operators';

// 模拟你的服务返回的Observable
const yourServiceData$ = of([1, 2, 3, 4, 5, 6]);

yourServiceData$.pipe(
  map((originalArray) => {
    const chunkSize = 2;
    const chunkedArray = [];
    
    // 循环截取每段2个元素的子数组
    for (let i = 0; i < originalArray.length; i += chunkSize) {
      chunkedArray.push(originalArray.slice(i, i + chunkSize));
    }
    
    return chunkedArray;
  })
).subscribe((result) => {
  console.log(result); // 输出: [[1, 2], [3, 4], [5, 6]]
});

这个方法的好处是逻辑透明，你还能灵活调整——比如如果原数组长度不是2的整数倍（比如[1,2,3,4,5]），最后一个子数组会是[5]，要是你想过滤短数组或者填充默认值，直接在循环里加判断就行。

方案2：用Lodash简化代码（若已引入Lodash） #

如果项目里已经在用Lodash，直接用它的chunk函数就能一行搞定转换：

import { of } from 'rxjs';
import { map } from 'rxjs/operators';
import { chunk } from 'lodash';

const yourServiceData$ = of([1, 2, 3, 4, 5, 6]);

yourServiceData$.pipe(
  map((arr) => chunk(arr, 2))
).subscribe((result) => {
  console.log(result); // 同样输出: [[1, 2], [3, 4], [5, 6]]
});

关键提醒 #

这里的前提是你的服务一次性返回整个数组。如果服务是逐个发射数组元素的（比如of(1,2,3,4,5,6)），那就要用bufferCount(2)操作符了，但根据你的描述，服务返回的是of([1,2,3,4,5,6])，所以上面的方案完全适用。

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