码迷,mamicode.com
首页 > Web开发 > 详细

[RxJS] Reactive Programming - New requests from refresh clicks -- merge()

时间:2016-03-08 20:57:38      阅读:152      评论:0      收藏:0      [点我收藏+]

标签:

Now we want each time we click refresh button, we will get new group of users. So we need to get the refresh button click event stream:

var refreshButton = document.querySelector(‘.refresh‘);
var refreshClickStream = Rx.Observable.fromEvent(refreshButton, ‘click‘);

 

Then each time refreshClickStream happens, we will get users request url:

var requestOnRefreshStream = refreshClickStream
  .map(ev => {
    var randomOffset = Math.floor(Math.random()*500);
    return ‘https://api.github.com/users?since=‘ + randomOffset;
  });

 

And we use this url to get json object:

var responseStream = requestOnRefreshStream
  .flatMap(requestUrl =>
    Rx.Observable.fromPromise(jQuery.getJSON(requestUrl))
  );

 

 

But the problem here is when the page loaded, we haven‘t click refresh button yet, therefore there is no data fetched fromt the server.

So we need to have a stream when the page loaded:

var startupRequestStream = Rx.Observable.just(‘https://api.github.com/users‘);

 

Then we can merge startUpRequestStream with requestOnRefreshStream:

var responseStream = requestOnRefreshStream
  .merge(startupRequestStream)
  .flatMap(requestUrl =>
    Rx.Observable.fromPromise(jQuery.getJSON(requestUrl))
  );

 

//-------a-----b-----c--------->
//s----------------------------->
//merge
//s------a-----b-----c--------->

 

[RxJS] Reactive Programming - New requests from refresh clicks -- merge()

标签:

原文地址:http://www.cnblogs.com/Answer1215/p/5255295.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!