Skip to content

Commit bb0ee07

Browse files
authored
fix: Fix resource leak causing CI test hangs in AsyncReplayBuffer (#101)
1 parent c45c665 commit bb0ee07

1 file changed

Lines changed: 6 additions & 0 deletions

File tree

src/PatternKit.Core/Behavioral/Iterator/AsyncFlow.cs

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -163,7 +163,13 @@ public async ValueTask<bool> TryGetAsync(int index, CancellationToken ct)
163163
using var reg = ct.Register(static s => ((TaskCompletionSource<bool>)s!).TrySetCanceled(), waiter);
164164
var signaled = await waiter.Task.ConfigureAwait(false);
165165
if (!signaled)
166+
{
167+
lock (_sync)
168+
{
169+
_waiters.Remove(waiter);
170+
}
166171
return false;
172+
}
167173
}
168174
}
169175

0 commit comments

Comments
 (0)