Function exec

docs/components/runtime.js:39–60

()

/* Run `src`, streaming each raw stdout chunk to `onChunk`. `onPhase` reports 'runtime'/'worker' (cold start only) then 'running'. Resolves with the error text (empty on success) and elapsed ms. */
export async function run(src, onChunk, onPhase) {
	const exec = async () => {
		// Only the run that triggers the cold start drives the load phases; warm runs go straight to 'running'.
		const worker = await getWorker(workerReady ? undefined : onPhase)
		onPhase?.('running')
		activeSink = onChunk
		let timer
		try {
			// Race against a hard timeout; terminate() kills the worker even mid-infinite-loop.
			const runP = worker.run(src, { baseUrl: location.href })
			runP.catch(() => {}) // loser of the race; killWorker rejects it with nobody listening
			const timeout = new Promise((_, reject) => { timer = setTimeout(() => reject(new Error(`Run exceeded ${RUN_TIMEOUT_MS / 1000}s — worker terminated`)), RUN_TIMEOUT_MS) })
			const { out, ms } = await Promise.race([runP, timeout])
			return { error: out || '', ms }
		} catch (e) {
			// Timeout or worker death: respawn so the queue isn't wedged forever.
			await killWorker()
			throw e
		} finally {
			clearTimeout(timer)
			activeSink = null
		}
	}
	// Queue behind any in-flight run (success or failure) so a second block never overwrites the first's activeSink mid-stream.
	const result = runChain.then(exec, exec)
	runChain = result.catch(() => {})