DooVDe

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

   var pool = Kefir.pool();