Skip to content

Instantly share code, notes, and snippets.

@bloodyKnuckles
Created October 14, 2017 17:38
Show Gist options
  • Save bloodyKnuckles/8e2aa2d1d9bd6454b550b627fcb83a07 to your computer and use it in GitHub Desktop.
Save bloodyKnuckles/8e2aa2d1d9bd6454b550b627fcb83a07 to your computer and use it in GitHub Desktop.
esnextbin sketch
<!doctype html>
<html>
<head>
<meta charset="utf-8">
<title>cycle js schedule driver</title>
</head>
<body>
<form>
<div id="app1"></div>
<div id="app2"></div>
</form>
</body>
</html>
import xs from 'xstream'
const source = xs.periodic(1).drop(1).take(3)
const a = source.map(v=>v*10)
const b = source.map(v=>v*100)
const hist:number[] = []
xs.merge(a,b).addListener({
next: v=>{ console.log(v); return hist.push(v) },
})
{
"name": "cycle js schedule driver",
"version": "0.0.0",
"dependencies": {
"xstream": "11.0.0"
}
}
'use strict';
var _xstream = require('xstream');
var _xstream2 = _interopRequireDefault(_xstream);
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
var source = _xstream2.default.periodic(1).drop(1).take(3);
var a = source.map(function (v) {
return v * 10;
});
var b = source.map(function (v) {
return v * 100;
});
var hist = [];
_xstream2.default.merge(a, b).addListener({
next: function next(v) {
console.log(v);return hist.push(v);
}
});
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment