From 56fe1e11359ba7db292379bc32401f4d6068a10a Mon Sep 17 00:00:00 2001
From: Nikolay Zdravkov <unsafeptr@gmail.com>
Date: Thu, 5 Nov 2026 05:50:04 +0200
Subject: [PATCH] fix: exercise competing lease consumers

---
 src/DotNext.Tests/Threading/Leases/LeaseTests.cs | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/src/DotNext.Tests/Threading/Leases/LeaseTests.cs b/src/DotNext.Tests/Threading/Leases/LeaseTests.cs
index 8731cde39e..358b91fa98 100644
--- a/src/DotNext.Tests/Threading/Leases/LeaseTests.cs
+++ b/src/DotNext.Tests/Threading/Leases/LeaseTests.cs
@@ -76,7 +76,7 @@ public static async Task FightForLeaseUsingConsumer()
         await using var consumer2 = new TestLeaseConsumer(provider);
 
         var acquisition1 = Task.Run(async () => await consumer1.TryAcquireAsync(TestToken), TestToken);
-        var acquisition2 = Task.Run(async () => await consumer1.TryAcquireAsync(TestToken), TestToken);
+        var acquisition2 = Task.Run(async () => await consumer2.TryAcquireAsync(TestToken), TestToken);
 
         var tasks = await Task.WhenAll(acquisition1, acquisition2);
 
@@ -98,7 +98,7 @@ public static async Task ConsumerTokenState()
 
         await consumer.Token.WaitAsync();
         await Task.Delay(provider.TimeToLive, TestToken);
-        
+
         False(await consumer.ReleaseAsync(TestToken));
     }
 
@@ -123,7 +123,7 @@ public static async Task AcquireUsingConsumer()
         True(await consumer.TryAcquireAsync(TestToken));
         await consumer.AcquireAsync(pause, Random.Shared, TestToken);
     }
-    
+
     [Fact]
     public static async Task WorkerProtectedWithLease()
     {
@@ -141,7 +141,7 @@ static async Task<int> Worker(CancellationToken token)
             return 42;
         }
     }
-    
+
     [Fact]
     public static async Task WorkerLeaseExpired()
     {
@@ -225,7 +225,7 @@ protected override void Dispose(bool disposing)
             base.Dispose(disposing);
         }
     }
-    
+
     private sealed class TestLeaseConsumer(TestLeaseProvider provider) : LeaseConsumer
     {
         protected override async ValueTask<AcquisitionResult?> TryAcquireCoreAsync(CancellationToken token = default)