$mol_wire_fiber: track changes while await

hyoo-ru · Nov 5, 2023 · 686be28 · 686be28
1 parent 6d5a980
commit 686be28
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/wire/fiber/fiber.ts b/wire/fiber/fiber.ts
@@ -265,7 +265,17 @@ namespace $ {
 
 				if( ! $mol_promise_like( this.cache ) ) return this.cache
 
-				await this.cache
+				await Promise.race([
+					this.cache,
+					new Promise( done => {
+						const sub = new $mol_wire_pub_sub
+						const prev = sub.track_on()
+						sub.track_next( this )
+						sub.track_off( prev )
+						sub.absorb = done
+					} )
+				])
+				if( ! $mol_promise_like( this.cache ) ) return this.cache
 
 				if( this.cursor === $mol_wire_cursor.final ) {
 					// never ends on destructed fiber