mocheng

var mqtt = require('mqtt');

var port = 1883;
var host = 'localhost';
var options = {
		username: 'my_username',
		password: 'my_password',
		clientId: 'my_client_id'
	};
var client = mqtt.createClient(port, host, options);

mocheng

mkdir -p ~/Downloads
cd ~/Downloads

sudo yum -y install zlib-devel openssl-devel cpio expat-devel gettext-devel curl-devel perl-ExtUtils-CBuilder perl-ExtUtils-MakeMaker

wget -O v1.8.1.2.tar.gz https://github.com/git/git/archive/v1.8.1.2.tar.gz

tar -xzvf ./v1.8.1.2.tar.gz
cd git-1.8.1.2/

mocheng

// Use Gists to store code you would like to remember later on
console.log(window); // log the "window" object to the console

mocheng

Array.prototype.ap = function(wrappedVals) {
	var results = [];

	this.map( (f)=> {
		const mr = wrappedVals.map(f);
		results = results.concat(mr);
	});

	return results;
}

mocheng

Array.prototype.flatMap = function(lambda) { 
  return [].concat.apply([], this.map(lambda)); 
};

const r = [1, 2, 3].flatMap(x => {
	var arr = new Array(x);
	for (var i=0; i<arr.length; ++i) {
		arr[i] = x;
	}
	return arr;

mocheng

const Rx = require('../../');
const fs = require('fs');
const t = require('transducers-js');

const source = Rx.Observable.range(1, 10000);
const increment = x => x + 1;
const isEven = x => (x % 2 === 0);

const startTime = new Date();
const transducer = t.comp(t.map(increment), t.filter(isEven));

mocheng

const Rx = require('../../');
const fs = require('fs');
const t = require('transducers-js');
const R = require('ramda');
const _ = require('lodash');

const mappingReducer = f => reducer => (result, input) => {
  //console.log('enter mappingReducer', result, input);
  return reducer(result, f(input));
};

mocheng

'use strict';

const Rx = require('rxjs');

const createStore = (reducer, initialState = {}) => {
	const action$ = new Rx.Subject();
	let currentState = initialState;

	const store$ = action$.startWith(initialState).scan(reducer).do(
		state => {