第一:这是我使用RxJs的第一个项目,我想我会通过使用它来学习.
我找到了这个答案:将分页请求转换为带有RxJs的Observable流 但是它在评论中说:
你仍然超过最大调用堆栈.大约430页返回.我认为递归可能不是最好的解决方案
我想查询Youtube Data API,结果以页面形式返回,我需要对它们进行分页.我想象这样的工作流程可以工作:1)发起呼叫2)检查响应是否有'nextPageToken'3)如果有,请对Youtube API做另一个请求4)如果没有,完成
So to do this I could Imagine the following Observables / streams:
FirstRequestStream -A-X--------------->
ResponseStream -A-A-A-A--X-------->
RequestStream -I-A-I-A----------->
A = Action
I = Info from upper stream
X = Termination
(不确定这个图表是否与我制作的方式一致)
所以ResponseStream依赖于FirstRequestStream和RequestStream(使用merge函数).RequestStream依赖于ResponseStream(这被称为循环可观察的吗？)
- 这是正确的方法吗？
- "流通的观察者"是一件好事,他们甚至可能吗？(我创造了一个问题).
- 我应该先尝试其他方式吗？
- 是否有可能创建相互依赖的可观察流？
谢谢您的帮助.