axefrog

// Limit the rate of flow to an event every 250ms:
// const stream$ = other$.thru(limitFlow(250));

export function limitFlow(period) {
  return function limitFlow(stream) {
    const source = new RateLimitSource(stream.source, period);
    return new stream.constructor(source);
  };
}

gbaman

Setting up Pi Zero OTG - The quick way (No USB keyboard, mouse, HDMI monitor needed)

More details - http://blog.gbaman.info/?p=791

For this method, alongside your Pi Zero, MicroUSB cable and MicroSD card, only an additional computer is required, which can be running Windows (with Bonjour, iTunes or Quicktime installed), Mac OS or Linux (with Avahi Daemon installed, for example Ubuntu has it built in).
1. Flash Raspbian Jessie full or Raspbian Jessie Lite onto the SD card.
2. Once Raspbian is flashed, open up the boot partition (in Windows Explorer, Finder etc) and add to the bottom of the config.txt file dtoverlay=dwc2 on a new line, then save the file.
3. If using a recent release of Jessie (Dec 2016 onwards), then create a new file simply called ssh in the SD card as well. By default SSH i

staltz

import {Observable, Disposable} from 'rx';
import {run} from '@cycle/core'
const jsondiffpatch = require('jsondiffpatch').create({
  objectHash: function(obj) {
    return obj.name;
  }
});

function generateCurve(steps){
  var curve = new Float32Array(steps)

manekinekko

let regex = `import
  (?:
    ["'\s]*
      ([\w*{}\n, ]+)
      from\s*
  )?
  ["'\s]*
    ([@\w/_-]+)
  ["'\s]*
;?

volodymyrprokopyuk

var _ = require('lodash');

var Success = function(success) { this.success = success; };
var Failure = function(failure) { this.failure = failure; };

var bindAll = function(fs) {
  var bind = function(res, f) {
    return res instanceof Success ? f(res.success) : res;
  };
  var bindF = function(f) { return _.partial(bind, _, f); };

kgryte

/* jshint esnext:true */

function get( target, prop, receiver ) {
  console.log( 'target: ' + target );
  console.log( 'property: ' + prop );
//   console.log( 'Receiver: ' + receiver );
  return Reflect.get( target, prop, receiver );
}

var handler = {

benjyhirsch

I was playing around with functional and reactive programming in Javascript, and the UI framework Cycle.js. In order to better understand how that framework works, I pared down the core functionality to a single concept: given a function that takes in an input stream and returns an output stream, resolve the circular dependency of feeding its output back into itself as input. I also built a naive re-implementation of the core Cycle.run command on top of that.

jamestalmage

Why

Doing require extensions correctly is essential, because:

1. Users should be able to install multiple extensions in succession, and have them work together.
2. Coverage tools like nyc need it to reliably supply coverage information that takes into account sourcemaps from upstream transforms.
3. Because non-standard, un-predictable behavior causes hard to solve bugs, and major headaches for project maintainers.

What is a require extension anyways?

gorangajic

update object

var state = {
    id: 1,
    points: 100,
    name: "Goran"
};

var newState = {

yvele

var Rx = require('rx');
var readline = require('readline');
var fs = require('fs');

var rl = readline.createInterface({
  input: fs.createReadStream('lines.txt')
});

var lines = Rx.Observable.fromEvent(rl, 'line')
  .takeUntil(Rx.Observable.fromEvent(rl, 'close'))