Brunobkr/llama.cpp_AlgMor24_github

1/** @import { Blocker, TemplateNode, Value } from '#client' */2import { flatten } from '../../reactivity/async.js';3import { get } from '../../runtime.js';4import {5	hydrate_next,6	hydrate_node,7	hydrating,8	set_hydrate_node,9	set_hydrating,10	skip_nodes11} from '../hydration.js';12 13/**14 * @param {TemplateNode} node15 * @param {Blocker[]} blockers16 * @param {Array<() => Promise<any>>} expressions17 * @param {(anchor: TemplateNode, ...deriveds: Value[]) => void} fn18 */19export function async(node, blockers = [], expressions = [], fn) {20	var was_hydrating = hydrating;21	var end = null;22 23	if (was_hydrating) {24		hydrate_next();25		end = skip_nodes(false);26	}27 28	if (expressions.length === 0 && blockers.every((b) => b.settled)) {29		fn(node);30 31		// This is necessary because it is not guaranteed that the render function will32		// advance the hydration node to $.async's end marker: it may stop at an inner33		// block's end marker (in case of an inner if block for example), but it also may34		// stop at the correct $.async end marker (in case of component child) - hence35		// we can't just use hydrate_next()36		// TODO this feels indicative of a bug elsewhere; ideally we wouldn't need37		// to double-traverse in the already-resolved case38		if (was_hydrating) {39			set_hydrate_node(end);40		}41 42		return;43	}44 45	if (was_hydrating) {46		var previous_hydrate_node = hydrate_node;47		set_hydrate_node(end);48	}49 50	flatten(blockers, [], expressions, (values) => {51		if (was_hydrating) {52			set_hydrating(true);53			set_hydrate_node(previous_hydrate_node);54		}55 56		try {57			// get values eagerly to avoid creating blocks if they reject58			for (const d of values) get(d);59 60			fn(node, ...values);61		} finally {62			if (was_hydrating) {63				set_hydrating(false);64			}65		}66	});67}68