tusharmath/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
// write ES2015 code and import modules from npm
// and then press "Execute" to run your program
import {Observable as O} from 'rx'

const log = (...t) => document.writeln(t.join('\t') + '<br/>')

function RAFThrottle (source) {
  return O.create(observer => {
    let queue = null

    function queueValue (value) {
      log('que', value)
      if(queue) {
        cancelAnimationFrame(queue)
      }
      queue = requestAnimationFrame(function () {
        log('req', value)
        observer.onNext(value)
      })
    }

    return source.subscribe(
      queueValue,
      err => observer.onError(err),
      () => observer.onCompleted()
    )
  })
}


const t= O.interval(1).take(10)

RAFThrottle(t).subscribe(x => log(x))

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

## transpiled.js
'use strict';

var _rx = require('rx');

var log = function log() {
  for (var _len = arguments.length, t = Array(_len), _key = 0; _key < _len; _key++) {
    t[_key] = arguments[_key];
  }

  return document.writeln(t.join('\t') + '<br/>');
}; // write ES2015 code and import modules from npm
// and then press "Execute" to run your program


function RAFThrottle(source) {
  return _rx.Observable.create(function (observer) {
    var queue = null;

    function queueValue(value) {
      log('que', value);
      if (queue) {
        cancelAnimationFrame(queue);
      }
      queue = requestAnimationFrame(function () {
        log('req', value);
        observer.onNext(value);
      });
    }

    return source.subscribe(queueValue, function (err) {
      return observer.onError(err);
    }, function () {
      return observer.onCompleted();
    });
  });
}

var t = _rx.Observable.interval(1).take(10);

RAFThrottle(t).subscribe(function (x) {
  return log(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>
	// write ES2015 code and import modules from npm
	// and then press "Execute" to run your program
	import {Observable as O} from 'rx'

	const log = (...t) => document.writeln(t.join('\t') + '<br/>')

	function RAFThrottle (source) {
	return O.create(observer => {
	let queue = null

	function queueValue (value) {
	log('que', value)
	if(queue) {
	cancelAnimationFrame(queue)
	}
	queue = requestAnimationFrame(function () {
	log('req', value)
	observer.onNext(value)
	})
	}

	return source.subscribe(
	queueValue,
	err => observer.onError(err),
	() => observer.onCompleted()
	)
	})
	}


	const t= O.interval(1).take(10)

	RAFThrottle(t).subscribe(x => log(x))
	{
	"name": "esnextbin-sketch",
	"dependencies": {
	"rx": "2.3.0"
	},
	"version": "0.0.0"
	}
	'use strict';

	var _rx = require('rx');

	var log = function log() {
	for (var _len = arguments.length, t = Array(_len), _key = 0; _key < _len; _key++) {
	t[_key] = arguments[_key];
	}

	return document.writeln(t.join('\t') + '<br/>');
	}; // write ES2015 code and import modules from npm
	// and then press "Execute" to run your program


	function RAFThrottle(source) {
	return _rx.Observable.create(function (observer) {
	var queue = null;

	function queueValue(value) {
	log('que', value);
	if (queue) {
	cancelAnimationFrame(queue);
	}
	queue = requestAnimationFrame(function () {
	log('req', value);
	observer.onNext(value);
	});
	}

	return source.subscribe(queueValue, function (err) {
	return observer.onError(err);
	}, function () {
	return observer.onCompleted();
	});
	});
	}

	var t = _rx.Observable.interval(1).take(10);

	RAFThrottle(t).subscribe(function (x) {
	return log(x);
	});