Skip to content

Commit 600b48e

Browse files
committed
refactor(pubsub): Simplify synchronization primitives in PubSub message handling
- Replace `Lock` with standard `object` for synchronization - Remove unnecessary blank lines in namespace declarations Signed-off-by: Joe Brinkman <[email protected]>
1 parent fa8bff7 commit 600b48e

File tree

2 files changed

+2
-3
lines changed

2 files changed

+2
-3
lines changed

sources/Valkey.Glide/PubSubMessageHandler.cs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
// Copyright Valkey GLIDE Project Contributors - SPDX Identifier: Apache-2.0
22

3-
43
namespace Valkey.Glide;
54

65
/// <summary>
@@ -19,7 +18,7 @@ internal sealed class PubSubMessageHandler : IDisposable
1918
private readonly MessageCallback? _callback;
2019
private readonly object? _context;
2120
private readonly PubSubMessageQueue _queue;
22-
private readonly Lock _lock = new();
21+
private readonly object _lock = new();
2322
private volatile bool _disposed;
2423

2524
/// <summary>

sources/Valkey.Glide/PubSubMessageQueue.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@ public sealed class PubSubMessageQueue : IDisposable
1313
{
1414
private readonly ConcurrentQueue<PubSubMessage> _messages;
1515
private readonly SemaphoreSlim _messageAvailable;
16-
private readonly Lock _lock = new();
16+
private readonly object _lock = new();
1717
private volatile bool _disposed;
1818

1919
/// <summary>

0 commit comments

Comments
 (0)