From 18b902344c16c23c22a456ba57243416c363a43a Mon Sep 17 00:00:00 2001
From: Rich Harris <rich.harris@vercel.com>
Date: Wed, 22 Jan 2025 20:56:52 -0500
Subject: [PATCH] each blocks

---
 .../3-transform/client/visitors/EachBlock.js  | 24 +++++++++++++++++--
 1 file changed, 22 insertions(+), 2 deletions(-)

diff --git a/packages/svelte/src/compiler/phases/3-transform/client/visitors/EachBlock.js b/packages/svelte/src/compiler/phases/3-transform/client/visitors/EachBlock.js
index 9f70981205..16bca733d4 100644
--- a/packages/svelte/src/compiler/phases/3-transform/client/visitors/EachBlock.js
+++ b/packages/svelte/src/compiler/phases/3-transform/client/visitors/EachBlock.js
@@ -283,11 +283,15 @@ export function EachBlock(node, context) {
 		);
 	}
 
+	const { is_async } = node.metadata.expression;
+
+	const thunk = each_node_meta.array_name ?? b.thunk(collection, is_async);
+
 	/** @type {Expression[]} */
 	const args = [
 		context.state.node,
 		b.literal(flags),
-		each_node_meta.array_name ? each_node_meta.array_name : b.thunk(collection),
+		is_async ? b.thunk(b.call('$.get', b.id('$$collection'))) : thunk,
 		key_function,
 		b.arrow(
 			uses_index ? [b.id('$$anchor'), item, index] : [b.id('$$anchor'), item],
@@ -301,7 +305,23 @@ export function EachBlock(node, context) {
 		);
 	}
 
-	context.state.init.push(b.stmt(b.call('$.each', ...args)));
+	if (is_async) {
+		context.state.init.push(
+			b.stmt(
+				b.call(
+					'$.async',
+					context.state.node,
+					b.array([thunk]),
+					b.arrow(
+						[context.state.node, b.id('$$collection')],
+						b.block([b.stmt(b.call('$.each', ...args))])
+					)
+				)
+			)
+		);
+	} else {
+		context.state.init.push(b.stmt(b.call('$.each', ...args)));
+	}
 }
 
 /**