briancavalier/esnextbin.md

## esnextbin.md

      
    Raw
  

              esnextbin.md
            
          
    made with esnextbin

  
## index.html
<!doctype html>
<html>
<head>
  <meta charset="utf-8">
  <title>ESNextbin Sketch</title>
  <!-- put additional styles and scripts here -->
</head>
<body>
  <!-- put markup and other contents here -->
</body>
</html>

## index.js
import { just, tap, periodic, throwError, recoverWith, delay, join } from 'most'

const retry = (ms, s) => nextRetry(ms, ms, s)

const nextRetry = (basems, currentms, s) => {
  let ok = false
  return recoverWith(() => ok
      ? nextRetry(basems, basems, s)
      : backoff(basems, currentms, s),
    tap(() => ok = true, s))
}

const backoff = (basems, currentms, s) =>
	join(delay(currentms, just(nextRetry(basems, currentms * 2, s))))

// Create a test stream that fails some number
// of times before finally succeeding
let attempts = 0
const s = periodic(1000, 'trying')
	.timestamp()
	.tap(x => console.log(x))
	.chain(x => ++attempts % 5 === 0 ? just(x) : throwError(x))

retry(200, s)
	.observe(x => console.log('here', x))

## package.json
{
  "name": "esnextbin-sketch",
  "version": "0.0.0",
  "dependencies": {
    "most": "1.0.5"
  }
}

## transpiled.js
'use strict';

var _most = require('most');

var retry = function retry(ms, s) {
  return nextRetry(ms, ms, s);
};

var nextRetry = function nextRetry(basems, currentms, s) {
  var ok = false;
  return (0, _most.recoverWith)(function () {
    return ok ? nextRetry(basems, basems, s) : backoff(basems, currentms, s);
  }, (0, _most.tap)(function () {
    return ok = true;
  }, s));
};

var backoff = function backoff(basems, currentms, s) {
  return (0, _most.join)((0, _most.delay)(currentms, (0, _most.just)(nextRetry(basems, currentms * 2, s))));
};

// Create a test stream that fails some number
// of times before finally succeeding
var attempts = 0;
var s = (0, _most.periodic)(1000, 'trying').timestamp().tap(function (x) {
  return console.log(x);
}).chain(function (x) {
  return ++attempts % 5 === 0 ? (0, _most.just)(x) : (0, _most.throwError)(x);
});

retry(200, s).observe(function (x) {
  return console.log('here', x);
});
	<!doctype html>
	<html>
	<head>
	<meta charset="utf-8">
	<title>ESNextbin Sketch</title>
	<!-- put additional styles and scripts here -->
	</head>
	<body>
	<!-- put markup and other contents here -->
	</body>
	</html>
	import { just, tap, periodic, throwError, recoverWith, delay, join } from 'most'

	const retry = (ms, s) => nextRetry(ms, ms, s)

	const nextRetry = (basems, currentms, s) => {
	let ok = false
	return recoverWith(() => ok
	? nextRetry(basems, basems, s)
	: backoff(basems, currentms, s),
	tap(() => ok = true, s))
	}

	const backoff = (basems, currentms, s) =>
	join(delay(currentms, just(nextRetry(basems, currentms * 2, s))))

	// Create a test stream that fails some number
	// of times before finally succeeding
	let attempts = 0
	const s = periodic(1000, 'trying')
	.timestamp()
	.tap(x => console.log(x))
	.chain(x => ++attempts % 5 === 0 ? just(x) : throwError(x))

	retry(200, s)
	.observe(x => console.log('here', x))
	{
	"name": "esnextbin-sketch",
	"version": "0.0.0",
	"dependencies": {
	"most": "1.0.5"
	}
	}
	'use strict';

	var _most = require('most');

	var retry = function retry(ms, s) {
	return nextRetry(ms, ms, s);
	};

	var nextRetry = function nextRetry(basems, currentms, s) {
	var ok = false;
	return (0, _most.recoverWith)(function () {
	return ok ? nextRetry(basems, basems, s) : backoff(basems, currentms, s);
	}, (0, _most.tap)(function () {
	return ok = true;
	}, s));
	};

	var backoff = function backoff(basems, currentms, s) {
	return (0, _most.join)((0, _most.delay)(currentms, (0, _most.just)(nextRetry(basems, currentms * 2, s))));
	};

	// Create a test stream that fails some number
	// of times before finally succeeding
	var attempts = 0;
	var s = (0, _most.periodic)(1000, 'trying').timestamp().tap(function (x) {
	return console.log(x);
	}).chain(function (x) {
	return ++attempts % 5 === 0 ? (0, _most.just)(x) : (0, _most.throwError)(x);
	});

	retry(200, s).observe(function (x) {
	return console.log('here', x);
	});