zackferrofields

var http = require('http');
var Rx = require('rx');

function observableServer(server) {
  return Rx.Observable.fromEventPattern(
    server.addListener.bind(server, 'request'),
    server.removeListener.bind(server, 'request'),
    (req, res) => ({req, res})
  ).takeUntil(Rx.Observable.fromEvent(server, 'close'));
}

zackferrofields

// ./app/Dockerfile

FROM node:4.1.0

WORKDIR /src/app
ADD package.json package.json

RUN npm install

zackferrofields

require('babel-core/register');
var babel = require('babel-core');
var gulp = require('gulp');
var speckjs = require('speckjs');
var tape = require('tape');
var through = require('through2');

function requireFromBuffer(buffer) {
  var m = new module.constructor();
  m.paths = module.paths;