tweinfeld’s gists

tweinfeld / private_message

Created May 13, 2015 08:41

tweinfeld / srt_loader

Created June 14, 2015 21:01

	define(["jquery", "lodash", "bacon"], function($, _, Bacon){

	return function(url, cb) {

	var parseTimeCode = function (timeCodeStr) {
	return _(timeCodeStr.split(/[:,]/))
	.map(Number)
	.zipWith([60 * 60 * 1000, 60 * 1000, 1000, 1], function(a, b){ return a * b; })
	.reduce(_.add, 0);
	};

tweinfeld / example.js

Last active May 28, 2016 23:11

A JSONP mixin for Lodash

	_.jsonp('https://api.ipify.org/?format=jsonp', function(err, value){
	console.log(err \|\| value);
	});

tweinfeld / concurrent_promise.js

Last active October 15, 2015 10:03

Limit execution concurrency of promise generation functions

	let allConcurrent = function(limit, generators){
	return new Promise(function(resolveAll){
	let plan = generators.map((generator)=>({ value: undefined, executed: false, settled: false, generator: generator }));
	let executeBatch = () => {
	plan
	.filter(({ settled, executed })=> !executed \|\| (executed && !settled))
	.slice(0, limit)
	.filter(({ executed }) => !executed)
	.map(planItem => {
	planItem.executed = true;

tweinfeld / baconjs_buffering_debounce.js

Last active October 22, 2015 06:57

Buffering Debounce with Bacon

	const QUEUE_TIMEOUT = 500,
	QUEUE_DEBOUNCE = 5;

	Bacon
	.repeatedly(10, ["*", "-"])
	.flatMapLatest((function(buffer, stamp) {
	return function(request) {
	buffer.length === 0 && (stamp = Date.now());
	buffer.push(request);
	return (stamp + QUEUE_TIMEOUT < Date.now()) ? Bacon.once(buffer.splice(0)) : Bacon.fromBinder(function(sink) {

tweinfeld / buffered_log.js

Last active May 28, 2016 15:48

	function createLogger(writer = console.log.bind(console), bufferThreshold = 100, delay = 5000){
	let buf = [], timer;
	const dispose = ()=>{ writer(buf.splice(0)); };
	return function(obj){
	buf.push(obj);
	clearTimeout(timer);
	(buf.length >= bufferThreshold ? dispose() : timer = setTimeout(dispose, delay));
	}
	}

tweinfeld / docker_shell.js

Last active November 25, 2016 10:27

Lib for executing command-line on Docker images. Shares similar interface to "child_process".

	const
	_ = require('lodash'),
	spawn = require('child_process').spawn,
	bacon = require('baconjs');

	const bufferUp = function(stream){
	return bacon
	.fromEvent(stream, 'data')
	.takeUntil(bacon.fromEvent(stream, 'close').take(1))
	.fold([], '.concat')

tweinfeld / 360_projector.js

Last active February 3, 2017 08:53

A rudimentary 360° video sphere projector. Receives a source element (i.e. <video/>) to read from and a destination <canvas/> to draw into.

	define([
	"jquery",
	"lodash",
	"three"
	], function(
	$,
	_,
	Three
	){
	var requestAnimationFrame = (window.requestAnimationFrame \|\| _.noop).bind(window),

tweinfeld / generator_promise_yielder.js

Created February 4, 2017 22:09

Generator Promise Yielder

	const run = function(gen, ...args){
	let iterator = gen.apply(undefined, args);
	return new Promise((resolve)=>{
	const rep = function(previousValue){
	let { done, value } = iterator[previousValue instanceof Error ? "throw" : "next"](previousValue);
	!done ? ((value instanceof Promise ? value.then((v)=>rep(v)).catch((v)=>rep(new Error(v))) : rep(value))) : resolve(value);
	}
	rep();
	})
	};

tweinfeld / frp_react.js

Last active February 9, 2017 13:29

React without Redux or Cycle.js

	const
	[div, span, button] = ["div", "span", "button"].map((name)=>React.createFactory(name)),
	myCounterComponent = function({ count, callback }){
	return div({}, [],
	button({ onClick: ()=>callback('decrease') }, ["-"]),
	span({}, [count]),
	button({ onClick: ()=>callback('increase') }, ["+"])
	);
	},
	myCounterCombo = function({ state: { counter_1, counter_2 }, callback }){

Tal Weinfeld tweinfeld