INNER CODE UNIT · TypeScript

packetsToProcess

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

    const packetsToProcess = this.options.maxPacketsPerTick * backlogFactor;

    const packets = this.packetQueue.splice(
      0,
      Math.min(packetsToProcess, this.packetQueue.length),
    );

    const pool = this.pool;
    if (!pool) return;
    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(

View source record →