Skip to content

Commit 5a63665

Browse files
committed
Fix cancellation registration
1 parent b60d854 commit 5a63665

File tree

1 file changed

+14
-14
lines changed

1 file changed

+14
-14
lines changed

Files/Helpers/AsyncManualResetEvent.cs

+14-14
Original file line numberDiff line numberDiff line change
@@ -14,8 +14,8 @@ public class AsyncManualResetEvent
1414
public Task WaitAsync(CancellationToken cancellationToken = default)
1515
{
1616
var tcs = m_tcs;
17-
using (cancellationToken.Register(
18-
s => ((TaskCompletionSource<bool>)s).TrySetCanceled(), tcs)) { }
17+
cancellationToken.Register(
18+
s => ((TaskCompletionSource<bool>)s).TrySetCanceled(), tcs);
1919

2020
return m_tcs.Task;
2121
}
@@ -24,23 +24,23 @@ public Task<bool> WaitAsync(int milliseconds, CancellationToken cancellationToke
2424
{
2525
var tcs = m_tcs;
2626

27-
using (cancellationToken.Register(
28-
s => ((TaskCompletionSource<bool>)s).TrySetCanceled(), tcs)) { }
27+
cancellationToken.Register(
28+
s => ((TaskCompletionSource<bool>)s).TrySetCanceled(), tcs);
2929

3030
var cancellationTokenSource = new CancellationTokenSource();
3131
cancellationTokenSource.CancelAfter(milliseconds);
32-
using (cancellationTokenSource.Token.Register(
33-
s =>
34-
{
35-
var l_tcs = (TaskCompletionSource<bool>)s;
32+
cancellationTokenSource.Token.Register(
33+
s =>
34+
{
35+
var l_tcs = (TaskCompletionSource<bool>)s;
3636

37-
if (!l_tcs.Task.IsCanceled)
38-
{
39-
l_tcs.TrySetResult(false);
40-
}
37+
if (!l_tcs.Task.IsCanceled)
38+
{
39+
l_tcs.TrySetResult(false);
40+
}
4141

42-
cancellationTokenSource.Dispose();
43-
}, tcs)) { }
42+
cancellationTokenSource.Dispose();
43+
}, tcs);
4444

4545
return m_tcs.Task;
4646
}

0 commit comments

Comments
 (0)