Function unpackStream

test/test-pack-codec.js:13–43

(stream)

var newPack;

function unpackStream(stream) {
  var meta, out = [], finished = false;
  var write = codec.decodePack(onItem);
  for (var i = 0, l = stream.length; i < l; i += 128) {
    var slice = bodec.slice(stream, i, i + 128);
    try {
      // console.log("SLICE", slice);
      write(slice);
    }
    catch (err) {
      throw err;
    }
  }
  write();

  function onItem(item) {
    // console.log("UNPACK", item);
    if (item === undefined) {
      finished = true;
    }
    else if (!meta) {
      meta = item;
    }
    else {
      out.push(item);
    }
  }
  if (!finished) throw new Error("unpack stream didn't finish");
  if (out.length !== meta.num) throw new Error("Item num mismatch");
  return out;
}


run([