Skip to content

Instantly share code, notes, and snippets.

@TylorS

TylorS/esnextbin.md

Created May 1, 2017 15:41
Show Gist options
  • Save TylorS/60cb017a92e3862dcd95a72b86acb9f6 to your computer and use it in GitHub Desktop.
Save TylorS/60cb017a92e3862dcd95a72b86acb9f6 to your computer and use it in GitHub Desktop.
Download ZIP
esnextbin sketch
Raw
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>
Raw
index.js
console.clear()
import { fromEvent, from, concat } from 'most'
import events from 'events'
const emitter = new events.EventEmitter()
const stream = fromEvent( 'event', emitter ).multicast()
const skipStream = stream.take( 1 )
const result = concat( stream.skip( 1 ) )
result.observe(console.log)
for ( let i = 1; i <= 5; i++ )
emitter.emit( 'event', i )
Raw
package.json
{
"name": "esnextbin-sketch",
"version": "0.0.0",
"dependencies": {
"most": "1.2.2",
"undefined": "v4.5.0"
}
}
Raw
transpiled.js
'use strict';
var _most = require('most');
var _events = require('events');
var _events2 = _interopRequireDefault(_events);
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
console.clear();
var emitter = new _events2.default.EventEmitter();
var stream = (0, _most.fromEvent)('event', emitter).multicast();
var skipStream = stream.take(1);
var result = (0, _most.concat)(stream.skip(1));
result.observe(console.log);
for (var i = 1; i <= 5; i++) {
emitter.emit('event', i);
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment