Kefir Recursive stream

function getStreamWrapper() {
   function getStream(pool) {
      return Kefir
         .sequentially(1000, [1, 2, 3])
         .onEnd(function(){
            pool.plug(getStream(pool));
         });
   }

   var pool = Kefir.pool();
   getStream(pool);
   pool.plug(stream);
   return pool;
}
getStreamWrapper().log()

function getStream () {
   var stream =  Kefir.sequentially(0, [1, 2, 3]);
   var end = stream
      .last()
      .flatMapLatest(getStream);

   return stream.merge(end);
}
getStream().log();