Function processNextFrame

apps/desktop/src/utils/socket.ts:1051–1081

()

	}

	function processNextFrame() {
		if (isProcessing) return;

		const buffer = nextFrame || pendingFrame;
		if (!buffer) return;

		if (nextFrame) {
			nextFrame = null;
		} else {
			pendingFrame = null;
		}

		isProcessing = true;

		const frameWorker = ensureWorker();
		if (producer) {
			const written = producer.write(buffer);
			if (!written) {
				sharedBufferFallbacks++;
				isProcessingSharedFrame = false;
				frameWorker.postMessage({ type: "frame", buffer }, [buffer]);
			} else {
				sharedBufferWrites++;
				isProcessingSharedFrame = true;
				frameWorker.postMessage({ type: "wake" });
			}
		} else {
			isProcessingSharedFrame = false;
			frameWorker.postMessage({ type: "frame", buffer }, [buffer]);
		}
	}

	ws.addEventListener("open", () => {
		setIsConnected(true);