Skip to content

Instantly share code, notes, and snippets.

@TimCodes
Created May 23, 2017 20:37
Show Gist options
  • Select an option

  • Save TimCodes/d73a64000c540082ba27449c3f22827b to your computer and use it in GitHub Desktop.

Select an option

Save TimCodes/d73a64000c540082ba27449c3f22827b to your computer and use it in GitHub Desktop.
RxJS 5 Operators // source http://jsbin.com/heduba
<!DOCTYPE html>
<html>
<head>
<meta charset="utf-8">
<meta name="viewport" content="width=device-width">
<title>RxJS 5 Operators</title>
<script src="https://npmcdn.com/@reactivex/[email protected]/dist/global/Rx.umd.js"></script>
</head>
<body>
<script id="jsbin-javascript">
"use strict";
//emit value every 1s
var source = Rx.Observable.interval(1000);
//sample last emitted value from source every 2s
var example = source.sample(Rx.Observable.interval(2000))
.scan(function (acc, curr) { return curr; });
//output: 2..4..6..8..
var subscribe = example.subscribe(function (val) { return console.log(val); });
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoianNiaW4uanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyJqc2Jpbi50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUEscUJBQXFCO0FBQ3JCLElBQU0sTUFBTSxHQUFHLEVBQUUsQ0FBQyxVQUFVLENBQUMsUUFBUSxDQUFDLElBQUksQ0FBQyxDQUFDO0FBQzVDLGlEQUFpRDtBQUNqRCxJQUFNLE9BQU8sR0FBRyxNQUFNLENBQUMsTUFBTSxDQUFDLEVBQUUsQ0FBQyxVQUFVLENBQUMsUUFBUSxDQUFDLElBQUksQ0FBQyxDQUFDO0tBQzFELElBQUksQ0FBQyxVQUFDLEdBQUcsRUFBRSxJQUFJLElBQU0sT0FBQSxJQUFJLEVBQUosQ0FBSSxDQUFDLENBQUM7QUFDNUIsc0JBQXNCO0FBQ3RCLElBQU0sU0FBUyxHQUFHLE9BQU8sQ0FBQyxTQUFTLENBQUMsVUFBQSxHQUFHLElBQUksT0FBQSxPQUFPLENBQUMsR0FBRyxDQUFDLEdBQUcsQ0FBQyxFQUFoQixDQUFnQixDQUFDLENBQUMiLCJzb3VyY2VzQ29udGVudCI6WyIvL2VtaXQgdmFsdWUgZXZlcnkgMXNcbmNvbnN0IHNvdXJjZSA9IFJ4Lk9ic2VydmFibGUuaW50ZXJ2YWwoMTAwMCk7XG4vL3NhbXBsZSBsYXN0IGVtaXR0ZWQgdmFsdWUgZnJvbSBzb3VyY2UgZXZlcnkgMnMgXG5jb25zdCBleGFtcGxlID0gc291cmNlLnNhbXBsZShSeC5PYnNlcnZhYmxlLmludGVydmFsKDIwMDApKVxuLnNjYW4oKGFjYywgY3VycikgPT4gIGN1cnIpO1xuLy9vdXRwdXQ6IDIuLjQuLjYuLjguLlxuY29uc3Qgc3Vic2NyaWJlID0gZXhhbXBsZS5zdWJzY3JpYmUodmFsID0+IGNvbnNvbGUubG9nKHZhbCkpOyJdfQ==
</script>
<script id="jsbin-source-javascript" type="text/javascript">//emit value every 1s
const source = Rx.Observable.interval(1000);
//sample last emitted value from source every 2s
const example = source.sample(Rx.Observable.interval(2000))
.scan((acc, curr) => curr);
//output: 2..4..6..8..
const subscribe = example.subscribe(val => console.log(val));</script></body>
</html>
"use strict";
//emit value every 1s
var source = Rx.Observable.interval(1000);
//sample last emitted value from source every 2s
var example = source.sample(Rx.Observable.interval(2000))
.scan(function (acc, curr) { return curr; });
//output: 2..4..6..8..
var subscribe = example.subscribe(function (val) { return console.log(val); });
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoianNiaW4uanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyJqc2Jpbi50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUEscUJBQXFCO0FBQ3JCLElBQU0sTUFBTSxHQUFHLEVBQUUsQ0FBQyxVQUFVLENBQUMsUUFBUSxDQUFDLElBQUksQ0FBQyxDQUFDO0FBQzVDLGlEQUFpRDtBQUNqRCxJQUFNLE9BQU8sR0FBRyxNQUFNLENBQUMsTUFBTSxDQUFDLEVBQUUsQ0FBQyxVQUFVLENBQUMsUUFBUSxDQUFDLElBQUksQ0FBQyxDQUFDO0tBQzFELElBQUksQ0FBQyxVQUFDLEdBQUcsRUFBRSxJQUFJLElBQU0sT0FBQSxJQUFJLEVBQUosQ0FBSSxDQUFDLENBQUM7QUFDNUIsc0JBQXNCO0FBQ3RCLElBQU0sU0FBUyxHQUFHLE9BQU8sQ0FBQyxTQUFTLENBQUMsVUFBQSxHQUFHLElBQUksT0FBQSxPQUFPLENBQUMsR0FBRyxDQUFDLEdBQUcsQ0FBQyxFQUFoQixDQUFnQixDQUFDLENBQUMiLCJzb3VyY2VzQ29udGVudCI6WyIvL2VtaXQgdmFsdWUgZXZlcnkgMXNcbmNvbnN0IHNvdXJjZSA9IFJ4Lk9ic2VydmFibGUuaW50ZXJ2YWwoMTAwMCk7XG4vL3NhbXBsZSBsYXN0IGVtaXR0ZWQgdmFsdWUgZnJvbSBzb3VyY2UgZXZlcnkgMnMgXG5jb25zdCBleGFtcGxlID0gc291cmNlLnNhbXBsZShSeC5PYnNlcnZhYmxlLmludGVydmFsKDIwMDApKVxuLnNjYW4oKGFjYywgY3VycikgPT4gIGN1cnIpO1xuLy9vdXRwdXQ6IDIuLjQuLjYuLjguLlxuY29uc3Qgc3Vic2NyaWJlID0gZXhhbXBsZS5zdWJzY3JpYmUodmFsID0+IGNvbnNvbGUubG9nKHZhbCkpOyJdfQ==
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment