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 xs from 'xstream'

const extend = (f, stream) =>
  stream.mapTo(stream.map(f))

const s = xs.periodic(1).take(10)

const logStream = s =>
  s.fold((x, y) => x.concat(y), []).last()
  .addListener({
    next: x => document.write('(' + x + ')\n'),
    error: () => {},
    complete: () => {}
  })

extend(x => x.take(3), s)
  .addListener({
    next: logStream,
    error: () => {},
    complete: () => {}
  })

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

## transpiled.js
'use strict';

var _xstream = require('xstream');

var _xstream2 = _interopRequireDefault(_xstream);

function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }

var extend = function extend(f, stream) {
  return stream.mapTo(stream.map(f));
};

var s = _xstream2.default.periodic(1).take(10);

var logStream = function logStream(s) {
  return s.fold(function (x, y) {
    return x.concat(y);
  }, []).last().addListener({
    next: function next(x) {
      return document.write('(' + x + ')\n');
    },
    error: function error() {},
    complete: function complete() {}
  });
};

extend(function (x) {
  return x.take(3);
}, s).addListener({
  next: logStream,
  error: function error() {},
  complete: function complete() {}
});
	<!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 xs from 'xstream'

	const extend = (f, stream) =>
	stream.mapTo(stream.map(f))

	const s = xs.periodic(1).take(10)

	const logStream = s =>
	s.fold((x, y) => x.concat(y), []).last()
	.addListener({
	next: x => document.write('(' + x + ')\n'),
	error: () => {},
	complete: () => {}
	})

	extend(x => x.take(3), s)
	.addListener({
	next: logStream,
	error: () => {},
	complete: () => {}
	})
	{
	"name": "esnextbin-sketch",
	"version": "0.0.0",
	"dependencies": {
	"xstream": "2.1.3"
	}
	}
	'use strict';

	var _xstream = require('xstream');

	var _xstream2 = _interopRequireDefault(_xstream);

	function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }

	var extend = function extend(f, stream) {
	return stream.mapTo(stream.map(f));
	};

	var s = _xstream2.default.periodic(1).take(10);

	var logStream = function logStream(s) {
	return s.fold(function (x, y) {
	return x.concat(y);
	}, []).last().addListener({
	next: function next(x) {
	return document.write('(' + x + ')\n');
	},
	error: function error() {},
	complete: function complete() {}
	});
	};

	extend(function (x) {
	return x.take(3);
	}, s).addListener({
	next: logStream,
	error: function error() {},
	complete: function complete() {}
	});