我有一个需求，
- 我点击按钮，
- 获得数组，长度为 100
- 我会使用其中三个
- 当我再次点击按钮的时候，我希望不用重新获得，因为还有 97 个未用完。直接 97 - 3 即可。
- 直到 100 个全部用完，才再次发送请求获取下一个 100 个数据。
求教，，， 或者说一下关键的思路，， 我是 rxjs 新手，百思不解了。。
推荐关注
› Meteor
› JSLint - a JavaScript code quality tool
› jsFiddle
› D3.js
› WebStorm
推荐书目
› JavaScript 权威指南第 5 版
› Closure: The Definitive Guide
› Closure: The Definitive Guide
This topic created in 2453 days ago, the information mentioned may be changed or developed.
 |
xcstreamFeb 15, 2020
1
思考了一下 好像不需要 rxjs 也很好写
|
 |
2
@xcstream 我在学 rxjs 这是我找的一个练习。。
|
 |
sivacohanFeb 15, 2020 via iPhone
3
我没用过 rxjs，你这个需求就是要实现个 queue。
每次远程取到的数据先入 queue，然后再从 queue 里面取数据到本地。 |
 |
godowayFeb 15, 2020
4
应该是背压？
在 rxjava 里面叫 Flowable，rxjs 里面好像没见有 |
 |
shadeofgodFeb 15, 2020
5
写了个类似的逻辑，数组长度是 3，每次消耗 1 个，消耗完了才重新请求。
https://codesandbox.io/s/4xk3kkok09?expanddevtools=1&fontsize=14&hidenavigation=1&theme=dark |
|
shadeofgodFeb 15, 2020
6
但感觉不太对，我也是很少用 rx
|
 |
PerryFeb 15, 2020 via iPhone
7
可能需要另外一条线 track 需不需要再请求
|
 |
cuzfinalFeb 15, 2020 via Android
8
你为什么不看看文档呢
|
 |
wly19960911Feb 15, 2020
10
datasource 的队列别拿 rxjs 做，这个是舍近求远的行为。只需要做个 queue 然后调用方法获取到队列前三位就行了。
直接 fromEvent(window, 'click').pipe( switchMap(v => fromPromise(datasource.get(3))), ).subscribe(() => {}); |
 |
11
Rx 是用来“推”数据的，而你的需求是“拉”数据，这就可以用到 IxJS： https://codesandbox.io/s/rx-ix-t21qn
|
1 |
lijshFeb 15, 2020
12
|
 |
momocraftFeb 15, 2020
13
什么叫"使用" "获得"?
|
|
14
@lijsh 我就是看了这篇，但是我做的东西和他又稍有不同。。。我增加了一些新特性。。
|
|
15
@wly19960911 你的意思是前端只管取就好了。。100 -3 的行为交给后端么。。
|
|
16
@momocraft 使用就是 view 层只需要显示 3 个。 获得就是发请求。
|
|
17
|
|
18
@shadeofgod 我研究下你这个代码。。
|
 |
yoyooyoooFeb 15, 2020
19
只是缓存个数组的话也没必要用 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(); |
 |
mxT52CRuqR6o5Feb 15, 2020
20
根据前面的评论学习了一下，这应该是背压问题，google 了一下有官方指导
http://reactivex.io/documentation/operators/backpressure.html 关键应该是在 ControlledObservable 上 |
|
wly19960911Feb 16, 2020
21
@weishijun14 datasource 不是指后端，单纯就是一个获取数据的库，至于背压问题我看了下，rxjs 不太好做这种重复，因为 rxjs 一开始就准备好了数据观测，除非有人手动触发了获取数据的操作。
switchMap 的 observable 也需要有 subject 来推数据进去。所以这个行为比较难以实现，不如写个库专门拿队列数据。由 rxjs 取就行了。如果不是需要重新拉取这个操作，我感觉挺好实现的... |
 |
StrayBugsFeb 16, 2020
22
大家这么快给实现，然而楼主的描述不是很完整。当请求 pending 时如果按下了按键怎么算？忽略还是算多次取？多次请求返回的结果怎么处理？抛弃旧的还是一并连起来？
|
|
shadeofgodFeb 17, 2020
23
@StrayBugs 你说的对，先定义清楚需求是更好的方式，不过对于闲逛论坛的人来说碰到每一个问题都像面试一样面对的话太累了。所以只是随手一写抛个思路
|
Select Language