TylorS/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 { Stream, multicast, just } from 'most'

const syncJust = a => new Stream(new Just(a))

class Just {
  constructor (a) {
    this.a = a
  }

  run (sink, scheduler) {
    sink.event(scheduler.now(), this.a)
    sink.end(scheduler.now(), this.a)

    return { dispose: Function.prototype }
  }
}

const running = stream => new Stream(new Running(stream.source))

class Running {
  constructor(source) {
    this.source = source
  }

  run(sink, scheduler) {
    console.log('running')
    return this.source.run(sink, scheduler)
  }
}

const foo$ = multicast(running(syncJust('foo')))

foo$.observe(x => console.log('1', x))
foo$.observe(x => console.log('2', x))

const bar$ = multicast(running(just('bar')))

bar$.observe(x => console.log('1', x))
bar$.observe(x => console.log('2', x))

## package.json
{
  "name": "esnextbin-sketch",
  "version": "0.0.0",
  "dependencies": {
    "most": "1.2.2",
    "babel-runtime": "6.22.0"
  }
}

## transpiled.js
'use strict';

var _classCallCheck2 = require('babel-runtime/helpers/classCallCheck');

var _classCallCheck3 = _interopRequireDefault(_classCallCheck2);

var _createClass2 = require('babel-runtime/helpers/createClass');

var _createClass3 = _interopRequireDefault(_createClass2);

var _most = require('most');

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

var syncJust = function syncJust(a) {
  return new _most.Stream(new Just(a));
};

var Just = function () {
  function Just(a) {
    (0, _classCallCheck3.default)(this, Just);

    this.a = a;
  }

  (0, _createClass3.default)(Just, [{
    key: 'run',
    value: function run(sink, scheduler) {
      sink.event(scheduler.now(), this.a);
      sink.end(scheduler.now(), this.a);

      return { dispose: Function.prototype };
    }
  }]);
  return Just;
}();

var running = function running(stream) {
  return new _most.Stream(new Running(stream.source));
};

var Running = function () {
  function Running(source) {
    (0, _classCallCheck3.default)(this, Running);

    this.source = source;
  }

  (0, _createClass3.default)(Running, [{
    key: 'run',
    value: function run(sink, scheduler) {
      console.log('running');
      return this.source.run(sink, scheduler);
    }
  }]);
  return Running;
}();

var foo$ = (0, _most.multicast)(running(syncJust('foo')));

foo$.observe(function (x) {
  return console.log('1', x);
});
foo$.observe(function (x) {
  return console.log('2', x);
});

var bar$ = (0, _most.multicast)(running((0, _most.just)('bar')));

bar$.observe(function (x) {
  return console.log('1', x);
});
bar$.observe(function (x) {
  return console.log('2', 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 { Stream, multicast, just } from 'most'

	const syncJust = a => new Stream(new Just(a))

	class Just {
	constructor (a) {
	this.a = a
	}

	run (sink, scheduler) {
	sink.event(scheduler.now(), this.a)
	sink.end(scheduler.now(), this.a)

	return { dispose: Function.prototype }
	}
	}

	const running = stream => new Stream(new Running(stream.source))

	class Running {
	constructor(source) {
	this.source = source
	}

	run(sink, scheduler) {
	console.log('running')
	return this.source.run(sink, scheduler)
	}
	}

	const foo$ = multicast(running(syncJust('foo')))

	foo$.observe(x => console.log('1', x))
	foo$.observe(x => console.log('2', x))

	const bar$ = multicast(running(just('bar')))

	bar$.observe(x => console.log('1', x))
	bar$.observe(x => console.log('2', x))
	{
	"name": "esnextbin-sketch",
	"version": "0.0.0",
	"dependencies": {
	"most": "1.2.2",
	"babel-runtime": "6.22.0"
	}
	}
	'use strict';

	var _classCallCheck2 = require('babel-runtime/helpers/classCallCheck');

	var _classCallCheck3 = _interopRequireDefault(_classCallCheck2);

	var _createClass2 = require('babel-runtime/helpers/createClass');

	var _createClass3 = _interopRequireDefault(_createClass2);

	var _most = require('most');

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

	var syncJust = function syncJust(a) {
	return new _most.Stream(new Just(a));
	};

	var Just = function () {
	function Just(a) {
	(0, _classCallCheck3.default)(this, Just);

	this.a = a;
	}

	(0, _createClass3.default)(Just, [{
	key: 'run',
	value: function run(sink, scheduler) {
	sink.event(scheduler.now(), this.a);
	sink.end(scheduler.now(), this.a);

	return { dispose: Function.prototype };
	}
	}]);
	return Just;
	}();

	var running = function running(stream) {
	return new _most.Stream(new Running(stream.source));
	};

	var Running = function () {
	function Running(source) {
	(0, _classCallCheck3.default)(this, Running);

	this.source = source;
	}

	(0, _createClass3.default)(Running, [{
	key: 'run',
	value: function run(sink, scheduler) {
	console.log('running');
	return this.source.run(sink, scheduler);
	}
	}]);
	return Running;
	}();

	var foo$ = (0, _most.multicast)(running(syncJust('foo')));

	foo$.observe(function (x) {
	return console.log('1', x);
	});
	foo$.observe(function (x) {
	return console.log('2', x);
	});

	var bar$ = (0, _most.multicast)(running((0, _most.just)('bar')));

	bar$.observe(function (x) {
	return console.log('1', x);
	});
	bar$.observe(function (x) {
	return console.log('2', x);
	});