如何在RxJS Observable中控制或过滤返回集合的对象数量？

嘿，这个需求很容易实现，咱们分两种常见场景来处理：

你的当前场景：Observable一次性发射完整数组 #

根据你的描述，service.$post()返回的是Observable<any[]>，也就是它会一次性把整个数组[{...}, {...}, ...]推送给你。这种情况下，我们只需要用map操作符配合数组的slice方法，就能筛选出你想要的元素数量：

取数组的前2个对象

// 直接对发射的数组做切片，取前2个元素
this.posts = this.service.$post().pipe(
  map(postsArray => postsArray.slice(0, 2))
);

slice(0, 2)的作用是从数组索引0开始，截取到索引2（不包含），正好得到前2个对象。

取任意范围的元素

如果不是要前2个，而是想取中间的某几个，比如第2到第3个对象（对应数组索引1到3），只需要调整slice的参数：

this.posts = this.service.$post().pipe(
  map(postsArray => postsArray.slice(1, 3))
);

拓展场景：Observable逐个发射数组元素 #

如果哪天你的服务逻辑调整，改成逐个发射数组里的每个对象（比如返回Observable<any>，每次推一个对象），那可以直接用RxJS的take操作符，它会帮你只接收前N个发射的元素，之后自动完成Observable：

import { take, toArray } from 'rxjs/operators';

// 只接收前2个对象，最后用toArray()把结果拼成数组
this.posts = this.service.$post().pipe(
  take(2),
  toArray()
);

总结一下，你的当前场景用map+slice是最直接的解决方案，完全能满足你只获取2个对象的需求~

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