请教一个 rxjs 问题。。。。。。

思考了一下 好像不需要 rxjs 也很好写

@xcstream 我在学 rxjs 这是我找的一个练习。。

我没用过 rxjs，你这个需求就是要实现个 queue。
每次远程取到的数据先入 queue，然后再从 queue 里面取数据到本地。

应该是背压？
在 rxjava 里面叫 Flowable，rxjs 里面好像没见有

写了个类似的逻辑，数组长度是 3，每次消耗 1 个，消耗完了才重新请求。

https://codesandbox.io/s/4xk3kkok09?expanddevtools=1&fOntsize=14&hidenavigation=1&theme=dark

但感觉不太对，我也是很少用 rx

可能需要另外一条线 track 需不需要再请求

你为什么不看看文档呢

@cuzfinal 你又知道人家没看过文档？

datasource 的队列别拿 rxjs 做，这个是舍近求远的行为。只需要做个 queue 然后调用方法获取到队列前三位就行了。

直接 fromEvent(window, 'click').pipe(
switchMap(v => fromPromise(datasource.get(3))),
).subscribe(() => {});

Rx 是用来“推”数据的，而你的需求是“拉”数据，这就可以用到 IxJS： https://codesandbox.io/s/rx-ix-t21qn

@lijsh 我就是看了这篇，但是我做的东西和他又稍有不同。。。我增加了一些新特性。。

@wly19960911 你的意思是前端只管取就好了。。100 -3 的行为交给后端么。。

@momocraft 使用就是 view 层只需要显示 3 个。 获得就是发请求。

@GiantHard 大佬又引入一个库啊。。。
@cuzfinal 文档也在看。。但是就是没有头绪。。

anyway 谢谢楼上各位大佬解答。。

@shadeofgod 我研究下你这个代码。。

只是缓存个数组的话也没必要用 rxjs，强行用的话另外搞个 BehaviorSubject 存起来好了，不是 rxjs 熟练工，简单实现：

const data$ = new BehaviorSubject([]);

fromEvent(document, "click")
.pipe(
withLatestFrom(data$),
switchMap(([e, data]) => {
return data.length < 3
? from(defer(() => mockFetch())).pipe(tap(v => data$.next(v)))
: of(data);
}),
tap(data => data$.next(data.slice(0, data.length - 3))),
tap(data => {
console.log(data);
})
)
.subscribe();

根据前面的评论学习了一下，这应该是背压问题，google 了一下有官方指导
http://reactivex.io/documentation/operators/backpressure.html
关键应该是在 ControlledObservable 上

@weishijun14 datasource 不是指后端，单纯就是一个获取数据的库，至于背压问题我看了下，rxjs 不太好做这种重复，因为 rxjs 一开始就准备好了数据观测，除非有人手动触发了获取数据的操作。

switchMap 的 observable 也需要有 subject 来推数据进去。所以这个行为比较难以实现，不如写个库专门拿队列数据。由 rxjs 取就行了。如果不是需要重新拉取这个操作，我感觉挺好实现的...

大家这么快给实现，然而楼主的描述不是很完整。当请求 pending 时如果按下了按键怎么算？忽略还是算多次取？多次请求返回的结果怎么处理？抛弃旧的还是一并连起来？

@StrayBugs 你说的对，先定义清楚需求是更好的方式，不过对于闲逛论坛的人来说碰到每一个问题都像面试一样面对的话太累了。所以只是随手一写抛个思路