INNER CODE UNIT · TypeScript

availableWorkers

voxelize/voxelize · packages/core/src/core/network/index.ts:567

    const availableWorkers = Math.max(1, pool.availableCount);
    const perWorker = Math.ceil(packets.length / availableWorkers);

    const batches: ArrayBuffer[][] = [];
    for (let i = 0; i < packets.length; i += perWorker) {
      batches.push(packets.slice(i, i + perWorker));
    }

    Promise.all(
      batches.map((batch, idx) =>
        this.decode(batch).then((msgs) => ({ idx, msgs })),
      ),
    ).then((results) => {
      if (!this.connected) {
        return;
      }

      results.sort((a, b) => a.idx - b.idx);

View source record →