cellvia

World traveler, electronic music enthusiast and composer, avid meditator and yogi, determined global citizen, and newly made father -- I am interested in vegetarianism, transcending paradox, frisbee, skateboarding, chess, and all things javascript. On any given day you may find me enjoying a round of heavy coding at the local Denver coworking space, or on a weekend retreat to the mountains of southern Colorado, dipping into the glorious hot springs to restore my chi.

I hope you enjoy my site. It was constructed by myself entirely (on the backs of giants, to be sure... huge shout out to substack and coenraets!) It was primarily created as an experimental proof of concept, however I quite like it, so I will use it to keep track of my creations, projects, and mental meanderings. If anything strikes your interest, please feel free to com

cellvia

var Redis = require('redis-stream');

var client = new Redis( settings.redisPort, settings.redisHost );

var keystream = client.stream('keys')

keystream.write('fogbugz:ticket:*');

keystream.on("end", function(){
    console.log("end");  /*returns all the keys properly, but NEVER ENDS*/

cellvia

//arguments = [pipe1, pipe2, pipe3];
  
var streams = [].slice.call(arguments);
  
streams.map(
  function(stream){  
    return 
      Object.keys(stream).reduce(function(s,k) { s[k] = stream[k]; return s }, Object.create(stream.__proto__));  
  }
);

cellvia

stream.js:81
      throw er; // Unhandled stream error in pipe.
            ^
Error: Unexpected "\u001f" at position 0 in state START
    at Parser.proto.charError (C:\node\work\crimson\Dev\node_modules\JSONStream\
node_modules\jsonparse\jsonparse.js:81:16)
    at Parser.proto.write (C:\node\work\crimson\Dev\node_modules\JSONStream\node
_modules\jsonparse\jsonparse.js:111:23)
    at Stream.exports.parse.stream.write (C:\node\work\crimson\Dev\node_modules\
JSONStream\index.js:83:12)

cellvia

var http = require('http');
var cicada = require('cicada');

var ci = cicada('./gittest');
ci.on('commit', function (commit) {
	console.log("commit");
/*    commit.run('test').on('exit', function (code) {
        var status = code === 0 ? 'PASSED' : 'FAILED';
        console.log(commit.hash + ' ' + status);
    });*/