Created
February 28, 2015 15:52
-
-
Save mitsuruog/3c139fd135149d067eb1 to your computer and use it in GitHub Desktop.
JS Bin RFP RxJSサンプル2 Github検索 // source http://jsbin.com/halopo
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<!DOCTYPE html> | |
<html> | |
<head> | |
<script src="http://cdnjs.cloudflare.com/ajax/libs/rxjs/2.3.24/rx.all.js"></script> | |
<script src="http://code.jquery.com/jquery-1.11.1.min.js"></script> | |
<meta name="description" content="RFP RxJSサンプル2 Github検索"> | |
<meta charset="utf-8"> | |
<title>JS Bin</title> | |
</head> | |
<body> | |
<input type="text" class="q"> | |
<div class="loading"></div> | |
<ul class="result"> | |
</ul> | |
<script id="jsbin-javascript"> | |
var $result = $('.result'); | |
var $loading = $('.loading'); | |
var executingStream = new Rx.Subject(); | |
var inputStream = Rx.Observable.fromEvent($('.q'), 'input') | |
.map(function(e) { | |
return e.target.value; | |
}); | |
var queryStream = inputStream | |
.throttle(500) | |
.filter(function(q) { | |
return q.length > 0; | |
}) | |
.distinctUntilChanged() | |
.map(function(q) { | |
return 'https://api.github.com/search/repositories?q=' + q; | |
}); | |
var repositoriesStream = queryStream | |
.flatMap(function(url) { | |
executingStream.onNext(true); | |
return Rx.Observable.fromPromise($.ajax(url)) | |
.finally(function() { | |
executingStream.onNext(false); | |
}); | |
}) | |
.map(function(response) { | |
return response.items; | |
}); | |
repositoriesStream.subscribe(function(repos) { | |
var appendRepos = $.each(repos, function() { | |
return $result.append('<li>' + this.full_name + '</li>'); | |
}); | |
}); | |
executingStream.subscribe(function(executing) { | |
if(executing) { | |
$loading.text('処理中...'); | |
} else { | |
$loading.text(''); | |
} | |
}); | |
</script> | |
<script id="jsbin-source-html" type="text/html"><!DOCTYPE html> | |
<html> | |
<head> | |
<script src="//cdnjs.cloudflare.com/ajax/libs/rxjs/2.3.24/rx.all.js"><\/script> | |
<script src="//code.jquery.com/jquery-1.11.1.min.js"><\/script> | |
<meta name="description" content="RFP RxJSサンプル2 Github検索"> | |
<meta charset="utf-8"> | |
<title>JS Bin</title> | |
</head> | |
<body> | |
<input type="text" class="q"> | |
<div class="loading"></div> | |
<ul class="result"> | |
</ul> | |
</body> | |
</html></script> | |
<script id="jsbin-source-javascript" type="text/javascript">var $result = $('.result'); | |
var $loading = $('.loading'); | |
var executingStream = new Rx.Subject(); | |
var inputStream = Rx.Observable.fromEvent($('.q'), 'input') | |
.map(function(e) { | |
return e.target.value; | |
}); | |
var queryStream = inputStream | |
.throttle(500) | |
.filter(function(q) { | |
return q.length > 0; | |
}) | |
.distinctUntilChanged() | |
.map(function(q) { | |
return 'https://api.github.com/search/repositories?q=' + q; | |
}); | |
var repositoriesStream = queryStream | |
.flatMap(function(url) { | |
executingStream.onNext(true); | |
return Rx.Observable.fromPromise($.ajax(url)) | |
.finally(function() { | |
executingStream.onNext(false); | |
}); | |
}) | |
.map(function(response) { | |
return response.items; | |
}); | |
repositoriesStream.subscribe(function(repos) { | |
var appendRepos = $.each(repos, function() { | |
return $result.append('<li>' + this.full_name + '</li>'); | |
}); | |
}); | |
executingStream.subscribe(function(executing) { | |
if(executing) { | |
$loading.text('処理中...'); | |
} else { | |
$loading.text(''); | |
} | |
});</script></body> | |
</html> |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
var $result = $('.result'); | |
var $loading = $('.loading'); | |
var executingStream = new Rx.Subject(); | |
var inputStream = Rx.Observable.fromEvent($('.q'), 'input') | |
.map(function(e) { | |
return e.target.value; | |
}); | |
var queryStream = inputStream | |
.throttle(500) | |
.filter(function(q) { | |
return q.length > 0; | |
}) | |
.distinctUntilChanged() | |
.map(function(q) { | |
return 'https://api.github.com/search/repositories?q=' + q; | |
}); | |
var repositoriesStream = queryStream | |
.flatMap(function(url) { | |
executingStream.onNext(true); | |
return Rx.Observable.fromPromise($.ajax(url)) | |
.finally(function() { | |
executingStream.onNext(false); | |
}); | |
}) | |
.map(function(response) { | |
return response.items; | |
}); | |
repositoriesStream.subscribe(function(repos) { | |
var appendRepos = $.each(repos, function() { | |
return $result.append('<li>' + this.full_name + '</li>'); | |
}); | |
}); | |
executingStream.subscribe(function(executing) { | |
if(executing) { | |
$loading.text('処理中...'); | |
} else { | |
$loading.text(''); | |
} | |
}); |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment