juliangruber

//
// initial
//

function observable(){
  var cur;
  var listeners = [];

  return function(val){

juliangruber

var connect = require('multilevel-connect');

var db = connect('password@host:port');

db.createReadStream()
.on('data', function(kv){
  console.log(JSON.stringify(kv));
})
.on('end', function(){
  process.exit(0)

juliangruber

description "nginx"
author "Julian Gruber <julian@segment.io>"

stop on shutdown

env DAEMON=/usr/sbin/nginx
env PID=/var/run/nginx.pid
env NGINX_ENV=dev

expect fork

juliangruber

var co = require('co');
var split = require('split');
var thunk = require('thunkify');
var pipe = thunk(require('multipipe'));
var read = require('co-read');
var write = require('co-write');
var JSONStream = require('JSONStream');

co(function*(){
  var headerData = {};

juliangruber

foo bar

neat, huh?...

juliangruber

foo bar
neat, huh?...

juliangruber

foo bar
neat, huh?

juliangruber

foo bar

juliangruber

foo bar

juliangruber

yield function(done){
  console.log('in yield');
  setTimeout(function(){
    console.log('after timeout');
    done();
  }, 0);
 }
 
console.log('waited')