Method writeStdin

src/ringbuffer.js:265–285

* Write stdin data * @param {Uint8Array|Buffer} data - Stdin data

(data)

    /**
     * Write a UDP datagram received by an existing NAT flow.
     * @param {Object} msg - { key, data }
     */
    writeUdpRecv(msg) {
        // Format: keyLen(1) + key + data. Endpoint metadata lives in the
        // worker's flow table, which also prevents spoofed reply addresses.
        const keyBytes = Buffer.from(msg.key, 'utf8');
        if (keyBytes.length > 255) return false;
        const dataBytes = Buffer.isBuffer(msg.data) ? msg.data : Buffer.from(msg.data);
        const payload = Buffer.alloc(1 + keyBytes.length + dataBytes.length);
        payload[0] = keyBytes.length;
        keyBytes.copy(payload, 1);
        dataBytes.copy(payload, 1 + keyBytes.length);
        return this.writeMessage(NET_MSG_UDP_RECV, payload);
    }
    
    /**
     * Write stdin data
     * @param {Uint8Array|Buffer} data - Stdin data
     */
    writeStdin(data) {
        // Wait for previous stdin to be consumed
        while (Atomics.load(this.int32, STDIN_FLAG_INDEX) !== 0) {
            // Busy wait - stdin should be consumed quickly
            Atomics.wait(this.int32, STDIN_FLAG_INDEX, 1, 5);