Flow cancellation token.

sharpjs · sharpjs · commit 03f041ebeb3d · 2022-05-07T13:01:03.000-07:00
diff --git a/DependencyQueue/DependencyQueue.cs b/DependencyQueue/DependencyQueue.cs
@@ -251,7 +251,7 @@ public void Enqueue(DependencyQueueEntry<T> entry)
             // for in-progress entries to complete and unblock some ready
             // entry(ies), or for one second to elapse, after which the
             // predicate might change its mind.
-            await @lock.ReleaseUntilPulseAsync(OneSecond);
+            await @lock.ReleaseUntilPulseAsync(OneSecond, cancellation);
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -251,7 +251,7 @@ public void Enqueue(DependencyQueueEntry<T> entry)`
`251`	`251`	`// for in-progress entries to complete and unblock some ready`
`252`	`252`	`// entry(ies), or for one second to elapse, after which the`
`253`	`253`	`// predicate might change its mind.`
`254`		`- await @lock.ReleaseUntilPulseAsync(OneSecond);`
	`254`	`+ await @lock.ReleaseUntilPulseAsync(OneSecond, cancellation);`
`255`	`255`	`}`
`256`	`256`	`}`
`257`	`257`