http://jsbin.com/roweju 에 해보고 있음.
Rx.Observable 에 fromEvent 를 붙여서 click 눌렀을 때 카운트가 올라가는 건 솔직히 잘 모르겠고 map으로 가공하고 최종결과를 subscribe 하는 패턴은 재미있다.
비동기 실행을 하는 부분은
Rx.Observable.create (observer)->
로 시작해서
observer.next( 리턴값 )
형식으로 끝나는 건 promise 랑 되게 비슷한 패턴이다.
.flatMap은
.map (url)-> sendRequest url, 'GET', null
.mergeAll()
* HTML
<!DOCTYPE html>
<html>
<head>
<script src="https://npmcdn.com/@reactivex/rxjs@5.0.0-beta.7/dist/global/Rx.umd.js"></script>
<meta charset="utf-8">
<meta name="viewport" content="width=device-width">
<title>JS Bin</title>
</head>
<body>
<button id="btn">click</button>
<p><span id="counter">1</span>th click</p>
<button id="btn-get">get posts</button>
<pre id="result">
</pre>
</body>
</html>
* Coffeescript
domainApi = 'http://jsonplaceholder.typicode.com'
document.addEventListener 'DOMContentLoaded', ->
# Count 올리기
btn = document.getElementById 'btn'
counter = document.getElementById 'counter'
Rx.Observable.fromEvent btn, 'click'
.map (e)->
e.stopPropagation()
console.log 'clicked'
parseInt(counter.innerText) + 1 # return value
.subscribe (a)->
counter.innerText = a
# AJAX 요청 가져오기
btnGet = document.getElementById 'btn-get'
result = document.getElementById 'result'
isDone = (xhr)->
xhr.status is 200 and xhr.readyState is XMLHttpRequest.DONE
sendRequest = (url, method, send)->
Rx.Observable.create (observer)->
xhr = new XMLHttpRequest()
xhr.onreadystatechange = ->
observer.next xhr.responseText if isDone xhr
xhr.open method, url, true
xhr.send send
Rx.Observable.fromEvent btnGet, 'click'
.map -> "#{domainApi}/posts"
.flatMap (url)-> sendRequest url, 'GET', null
.map (res)->
JSON.parse res
.map (res)->
title:v.title, body: v.body for v in res
.subscribe (res)->
result.innerHTML = JSON.stringify res
Rx.Observable 에 fromEvent 를 붙여서 click 눌렀을 때 카운트가 올라가는 건 솔직히 잘 모르겠고 map으로 가공하고 최종결과를 subscribe 하는 패턴은 재미있다.
비동기 실행을 하는 부분은
Rx.Observable.create (observer)->
로 시작해서
observer.next( 리턴값 )
형식으로 끝나는 건 promise 랑 되게 비슷한 패턴이다.
.flatMap은
.map (url)-> sendRequest url, 'GET', null
.mergeAll()
이 두개를 합친 것이라고 보면 됨.
<!DOCTYPE html>
<html>
<head>
<script src="https://npmcdn.com/@reactivex/rxjs@5.0.0-beta.7/dist/global/Rx.umd.js"></script>
<meta charset="utf-8">
<meta name="viewport" content="width=device-width">
<title>JS Bin</title>
</head>
<body>
<button id="btn">click</button>
<p><span id="counter">1</span>th click</p>
<button id="btn-get">get posts</button>
<pre id="result">
</pre>
</body>
</html>
* Coffeescript
domainApi = 'http://jsonplaceholder.typicode.com'
document.addEventListener 'DOMContentLoaded', ->
# Count 올리기
btn = document.getElementById 'btn'
counter = document.getElementById 'counter'
Rx.Observable.fromEvent btn, 'click'
.map (e)->
e.stopPropagation()
console.log 'clicked'
parseInt(counter.innerText) + 1 # return value
.subscribe (a)->
counter.innerText = a
# AJAX 요청 가져오기
btnGet = document.getElementById 'btn-get'
result = document.getElementById 'result'
isDone = (xhr)->
xhr.status is 200 and xhr.readyState is XMLHttpRequest.DONE
sendRequest = (url, method, send)->
Rx.Observable.create (observer)->
xhr = new XMLHttpRequest()
xhr.onreadystatechange = ->
observer.next xhr.responseText if isDone xhr
xhr.open method, url, true
xhr.send send
Rx.Observable.fromEvent btnGet, 'click'
.map -> "#{domainApi}/posts"
.flatMap (url)-> sendRequest url, 'GET', null
.map (res)->
JSON.parse res
.map (res)->
title:v.title, body: v.body for v in res
.subscribe (res)->
result.innerHTML = JSON.stringify res
댓글
댓글 쓰기