$mol_wire_fiber: step api

hyoo-ru · Nov 5, 2023 · dabf7fd · dabf7fd
1 parent c48f155
commit dabf7fd
Showing 1 changed file with 14 additions and 10 deletions.
diff --git a/wire/fiber/fiber.ts b/wire/fiber/fiber.ts
@@ -265,16 +265,7 @@ namespace $ {
 
 				if( ! $mol_promise_like( this.cache ) ) return 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
-					} )
-				])
+				await Promise.race([ this.cache, this.step() ])
 				if( ! $mol_promise_like( this.cache ) ) return this.cache
 
 				if( this.cursor === $mol_wire_cursor.final ) {
@@ -286,6 +277,19 @@ namespace $ {
 
 		}
 
+		step() {
+			return new Promise< null >( done => {
+				const sub = new $mol_wire_pub_sub
+				const prev = sub.track_on()
+				sub.track_next( this )
+				sub.track_off( prev )
+				sub.absorb = ()=> {
+					done( null )
+					sub.destructor()
+				}
+			} )
+		}
+
 	}
 
 }