"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==