supershabam/index.html

## index.html
<!DOCTYPE html>
<html>
<head>
<script src="http://cdnjs.cloudflare.com/ajax/libs/rxjs/2.3.22/rx.all.js"></script>
  <meta charset="utf-8">
  <title>JS Bin</title>
</head>
<body>

<script id="jsbin-javascript">
var fn = function() {
  console.log(new Date().toString());
  return new Promise(function(resolve, reject) {
    var timeout = Math.random() * 2000 + 500;
    console.log('running for', timeout);
    setTimeout(function() {
      resolve('done');
    }, timeout);
  });
};

// ticker will run at most one fn at a time attempting
// to run it on a consistent schedule set by the splay
// and period. If the function is still executing when
// a scheduled run occurs, then the function is not
// called.
function ticker(splay, period, fn) {
  var isRunning = false;
  return Rx.Observable.timer(splay, period).
    filter(function() {
      return !isRunning;
    }).
    flatMap(function() {
      isRunning = true;
      var p = fn();
      p.then(function() {
        isRunning = false;
      });
      return p;
    });
}

ticker(500, 2000, fn).subscribe(function(x) {
  console.log(x);
});
</script>

<script id="jsbin-source-html" type="text/html"><!DOCTYPE html>
<html>
<head>
<script src="//cdnjs.cloudflare.com/ajax/libs/rxjs/2.3.22/rx.all.js"><\/script>
  <meta charset="utf-8">
  <title>JS Bin</title>
</head>
<body>

</body>
</html></script>


<script id="jsbin-source-javascript" type="text/javascript">var fn = function() {
  console.log(new Date().toString());
  return new Promise(function(resolve, reject) {
    var timeout = Math.random() * 2000 + 500;
    console.log('running for', timeout);
    setTimeout(function() {
      resolve('done');
    }, timeout);
  });
};

// ticker will run at most one fn at a time attempting
// to run it on a consistent schedule set by the splay
// and period. If the function is still executing when
// a scheduled run occurs, then the function is not
// called.
function ticker(splay, period, fn) {
  var isRunning = false;
  return Rx.Observable.timer(splay, period).
    filter(function() {
      return !isRunning;
    }).
    flatMap(function() {
      isRunning = true;
      var p = fn();
      p.then(function() {
        isRunning = false;
      });
      return p;
    });
}

ticker(500, 2000, fn).subscribe(function(x) {
  console.log(x);
});


</script></body>
</html>

## jsbin.gujatabahu.js
var fn = function() {
  console.log(new Date().toString());
  return new Promise(function(resolve, reject) {
    var timeout = Math.random() * 2000 + 500;
    console.log('running for', timeout);
    setTimeout(function() {
      resolve('done');
    }, timeout);
  });
};

// ticker will run at most one fn at a time attempting
// to run it on a consistent schedule set by the splay
// and period. If the function is still executing when
// a scheduled run occurs, then the function is not
// called.
function ticker(splay, period, fn) {
  var isRunning = false;
  return Rx.Observable.timer(splay, period).
    filter(function() {
      return !isRunning;
    }).
    flatMap(function() {
      isRunning = true;
      var p = fn();
      p.then(function() {
        isRunning = false;
      });
      return p;
    });
}

ticker(500, 2000, fn).subscribe(function(x) {
  console.log(x);
});
	<!DOCTYPE html>
	<html>
	<head>
	<script src="http://cdnjs.cloudflare.com/ajax/libs/rxjs/2.3.22/rx.all.js"></script>
	<meta charset="utf-8">
	<title>JS Bin</title>
	</head>
	<body>

	<script id="jsbin-javascript">
	var fn = function() {
	console.log(new Date().toString());
	return new Promise(function(resolve, reject) {
	var timeout = Math.random() * 2000 + 500;
	console.log('running for', timeout);
	setTimeout(function() {
	resolve('done');
	}, timeout);
	});
	};

	// ticker will run at most one fn at a time attempting
	// to run it on a consistent schedule set by the splay
	// and period. If the function is still executing when
	// a scheduled run occurs, then the function is not
	// called.
	function ticker(splay, period, fn) {
	var isRunning = false;
	return Rx.Observable.timer(splay, period).
	filter(function() {
	return !isRunning;
	}).
	flatMap(function() {
	isRunning = true;
	var p = fn();
	p.then(function() {
	isRunning = false;
	});
	return p;
	});
	}

	ticker(500, 2000, fn).subscribe(function(x) {
	console.log(x);
	});
	</script>

	<script id="jsbin-source-html" type="text/html"><!DOCTYPE html>
	<html>
	<head>
	<script src="//cdnjs.cloudflare.com/ajax/libs/rxjs/2.3.22/rx.all.js"><\/script>
	<meta charset="utf-8">
	<title>JS Bin</title>
	</head>
	<body>

	</body>
	</html></script>


	<script id="jsbin-source-javascript" type="text/javascript">var fn = function() {
	console.log(new Date().toString());
	return new Promise(function(resolve, reject) {
	var timeout = Math.random() * 2000 + 500;
	console.log('running for', timeout);
	setTimeout(function() {
	resolve('done');
	}, timeout);
	});
	};

	// ticker will run at most one fn at a time attempting
	// to run it on a consistent schedule set by the splay
	// and period. If the function is still executing when
	// a scheduled run occurs, then the function is not
	// called.
	function ticker(splay, period, fn) {
	var isRunning = false;
	return Rx.Observable.timer(splay, period).
	filter(function() {
	return !isRunning;
	}).
	flatMap(function() {
	isRunning = true;
	var p = fn();
	p.then(function() {
	isRunning = false;
	});
	return p;
	});
	}

	ticker(500, 2000, fn).subscribe(function(x) {
	console.log(x);
	});


	</script></body>
	</html>