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
console.clear()
import {Observable as O} from 'rx'

function RAFThrottle(source) {
  return O.create(observer => {
    let value
    let canUpdate = false

    function update () {
      if (canUpdate) {
        observer.onNext(value)
        canUpdate = false
        requestAnimationFrame(() => canUpdate = true)
      } else {
        console.log('-', value)
      }

    }
    requestAnimationFrame(() => canUpdate = true)
    source.subscribe(x => {
        value = x
        update()
      },
      err => observer.onError(err),
      () => observer.onCompleted()
    )
  })
}

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

RAFThrottle(t).subscribe(x => console.log('+', x))

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

## transpiled.js
'use strict';

var _rx = require('rx');

// write ES2015 code and import modules from npm
// and then press "Execute" to run your program
console.clear();


function RAFThrottle(source) {
  return _rx.Observable.create(function (observer) {
    var value = void 0;
    var canUpdate = false;

    function update() {
      if (canUpdate) {
        observer.onNext(value);
        canUpdate = false;
        requestAnimationFrame(function () {
          return canUpdate = true;
        });
      } else {
        console.log('-', value);
      }
    }
    requestAnimationFrame(function () {
      return canUpdate = true;
    });
    source.subscribe(function (x) {
      value = x;
      update();
    }, function (err) {
      return observer.onError(err);
    }, function () {
      return observer.onCompleted();
    });
  });
}

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

RAFThrottle(t).subscribe(function (x) {
  return console.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
	console.clear()
	import {Observable as O} from 'rx'

	function RAFThrottle(source) {
	return O.create(observer => {
	let value
	let canUpdate = false

	function update () {
	if (canUpdate) {
	observer.onNext(value)
	canUpdate = false
	requestAnimationFrame(() => canUpdate = true)
	} else {
	console.log('-', value)
	}

	}
	requestAnimationFrame(() => canUpdate = true)
	source.subscribe(x => {
	value = x
	update()
	},
	err => observer.onError(err),
	() => observer.onCompleted()
	)
	})
	}

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

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

	var _rx = require('rx');

	// write ES2015 code and import modules from npm
	// and then press "Execute" to run your program
	console.clear();


	function RAFThrottle(source) {
	return _rx.Observable.create(function (observer) {
	var value = void 0;
	var canUpdate = false;

	function update() {
	if (canUpdate) {
	observer.onNext(value);
	canUpdate = false;
	requestAnimationFrame(function () {
	return canUpdate = true;
	});
	} else {
	console.log('-', value);
	}
	}
	requestAnimationFrame(function () {
	return canUpdate = true;
	});
	source.subscribe(function (x) {
	value = x;
	update();
	}, function (err) {
	return observer.onError(err);
	}, function () {
	return observer.onCompleted();
	});
	});
	}

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

	RAFThrottle(t).subscribe(function (x) {
	return console.log('+', x);
	});