zoukankan      html  css  js  c++  java
  • [Reactive Programming] Async requests and responses in RxJS

    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() function
      var 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.

  • 相关阅读:
    今天开始学习WCF了开发环境的配置
    我的文章《DLL封装登录框架实现代码复用》终于要发表了
    python小练习给右键菜单添加用chrome打开
    手动创建oracle数据库
    Sublime Text 2中如何输入中文
    转 用Python画Mandelbrot集
    Win7 64位安装Python PIL库
    推荐一本有关设计的好书《写给大家看的设计书》
    坚持做自己
    更新专业版显卡驱动导致ubuntu无法进入桌面环境
  • 原文地址:https://www.cnblogs.com/Answer1215/p/4857602.html
Copyright © 2011-2022 走看看