makeStream(setStream)

var Kefir = require('kefir');
var count = Kefir.sequentially(1000, [1, 2]);

var myCompute = canStream.toCompute(function(setStream) {
    return setStream.merge(count);
});