bjoerge

// Based on https://github.com/Reactive-Extensions/RxJS/tree/master/examples/autocomplete

var Rx = require("rx-dom");
var querystring = require("querystring");
var jsonp = require("jsonp");

function searchWikipedia(term) {
  return new Promise((resolve, reject) => {

    var params = querystring.stringify({

bjoerge

var EventEmitter = require("events").EventEmitter;

function PathEmitter() {
  window.addEventListener('popstate', this._emitNavigate.bind(this));  
  EventEmitter.call(this);
}

PathEmitter.prototype = new EventEmitter();

PathEmitter.prototype._emitNavigate = function _emitNavigate() {

bjoerge

alias useio='ln -sf /usr/local/bin/iojs /usr/local/bin/node && node -v'
alias usenode='(brew unlink node && brew link --overwrite node) > /dev/null &&  node -v'

bjoerge

var concat = require('concat-stream');

function parseCSV(file) { 
    var parser = csvParse({
     delimiter: ',',
 	   auto_parse: true,
  	 columns: true
	});
  
  return new Promise(function(resolve, reject) {

bjoerge

.playerContainer {
  position: relative;
}

.playerContainer object {
  height: 100%;
  left: 0;
  top: 0;
  position: absolute;
  width: 100%;

bjoerge

const Rx = require('rx');
const csv = require('csv-parse');
const fs = require('fs');

Rx.Node.fromReadableStream(fs.createReadStream('file.csv').pipe(csv()))
  .skip(1)
  .withLatestFrom(rows.take(1), (row, header) => {
    // Map header[i] => row[i]  
    return row.reduce((rowObj, cell, i) => {
      rowObj[header[i]] = cell;

bjoerge

const assert = require("assert");

function skipSingleKeys(obj) {
  if (obj === null || typeof obj !== 'object') {
    return obj;
  }
  const keys = Object.keys(obj);
  if (keys.length == 1) {
    return skipSingleKeys(obj[keys[0]]);
  }

bjoerge

.DS_Store
npm-debug.log
node_modules

bjoerge

Minimalistic pubsub

function pubsubber() {
  const subscribers = []
  return {
    subscribe,
    once,
    publish
 }

bjoerge

import url from 'url'

export default Object.assign(configure(), configure)

function configure({qsImpl} = {}) {
  return {
    parse(urlToParse) {
      return Object.assign(createUrlObject({qsImpl}), {
        href: urlToParse
      })