[Reactive Programming] Async requests and responses in RxJS
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了[Reactive Programming] Async requests and responses in RxJS，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1915字，纯文字阅读大概需要3分钟。
内容图文
We will learn how to perform network requests to a backend using RxJS Observables.
A example of basic jquery request:
console.clear();
var requestStream = Rx.Observable.just(‘https://api.github.com/users‘);
//Current requestStream is just a stream
//We need to subscribe it to make it work
requestStream.subscribe(url => {
//Preform a serve reqest by jQuery
jQuery.getJSON(url).done( res => {
console.log(res);
})
});
But it not make so many sence we use jQuery to handle the promise since we already using RxJS:
console.clear();
var requestStream = Rx.Observable.just(‘https://api.github.com/users‘);
//Current requestStream is just a stream
//We need to subscribe it to make it work
requestStream.subscribe( url => {
//Using Rx.Observable.fromPromise() to handle the response//Since jQuery.getJSON(url) return a promise//there we put into the fromPromise() functionvar responseStream = Rx.Observable.fromPromise(jQuery.getJSON(url));
//Then subscribe the responseStream
responseStream.subscribe( res => {
console.log(res);
});
});
We see that we can accomplish with promise we also can do in Observable. And the main problem for promise is that promise only even yield a single value. But observalbe can have mult events.
But soon we find we subscribe an stream inside another subscribe, this is what we don‘t have to do, normal way to avoid this is using flatMap().
Here we do flagMap() but not map() is because inside map() a observable and return another observable then we got an observable of observable.
console.clear();
var requestStream = Rx.Observable.just(‘https://api.github.com/users‘);
var responseStream = requestStream
.flatMap( url => Rx.Observable.fromPromise(jQuery.getJSON(url)));
responseStream.subscribe( res => console.log(res));
Now we have only one subscribe.
原文：http://www.cnblogs.com/Answer1215/p/4857602.html
内容总结
以上是互联网集市为您收集整理的[Reactive Programming] Async requests and responses in RxJS全部内容，希望文章能够帮你解决[Reactive Programming] Async requests and responses in RxJS所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。