Method readNetworkMessage

src/ringbuffer.js:337–369

* Read next network message (returns null if none available) * @returns {Object|null} - { type, payload } or null

()

     * @returns {Object|null} - { type, payload } or null
     */
    readNetworkMessage() {
        const head = Atomics.load(this.int32, NET_HEAD_INDEX);
        let tail = Atomics.load(this.int32, NET_TAIL_INDEX);
        
        if (head === tail) {
            return null; // Empty
        }
        
        const ringStart = NET_RING_OFFSET;
        
        // Read length (2 bytes, little-endian)
        const lenLow = this.uint8[ringStart + tail];
        tail = (tail + 1) % NET_RING_SIZE;
        const lenHigh = this.uint8[ringStart + tail];
        tail = (tail + 1) % NET_RING_SIZE;
        const payloadLen = lenLow | (lenHigh << 8);
        
        // Read type (1 byte)
        const type = this.uint8[ringStart + tail];
        tail = (tail + 1) % NET_RING_SIZE;
        
        // Read payload
        const payload = Buffer.alloc(payloadLen);
        for (let i = 0; i < payloadLen; i++) {
            payload[i] = this.uint8[ringStart + tail];
            tail = (tail + 1) % NET_RING_SIZE;
        }
        
        // Update tail atomically
        Atomics.store(this.int32, NET_TAIL_INDEX, tail);
        
        return { type, payload };
    }
    
    /**
     * Parse TCP data message