<!DOCTYPE html>
<html lang="en" >
<head>
<meta charset="UTF-8">
<title>RxJS playground</title>
</head>
<body>
<input type="text" id="text">
<button id="click">click</button>
<script src='https://unpkg.com/@reactivex/rxjs@5.0.1/dist/global/Rx.js'></script>
<script src='https://cdnjs.cloudflare.com/ajax/libs/lodash.js/4.17.4/lodash.min.js'></script>
<script src="js/index.js"></script>
</body>
</html>
/*Downloaded from https://www.codeseek.co/1kohei1/rxjs-playground-veNgaO */
let p1 = () => {
return Promise.resolve(1);
};
let p2 = () => {
return Promise.resolve(2);
}
let queue = new Rx.BehaviorSubject();
queue
.mergeMap(num => {
const delay = Math.random() * 10000;
console.log(`Execute ${num} in ${delay} milliseconds`);
// return Rx.Observable.timer(delay, 1000)
// .take(1)
return Promise.all([p1, p2]);
}, null, 2)
.subscribe(x => {
console.log(x);
});
const clickObservable = Rx.Observable.fromEvent(
document.getElementById('click'),
'click'
);
clickObservable.subscribe(event => {
let nums = document.getElementById('text').value.split(',');
nums = _.filter(nums, (num) => {
return !!num
})
nums = _.map(nums, (num) => {
return _.trim(num);
});
_.forEach(nums, num => {
queue.next(num);
})
});
Bootstrap
Angular
ReactJS
jQuery
VueJS
HTML
CSS
JavaScript
React
RxJS
