Skip to content

Commit 5c806cf

Browse files
committed
style: Apply code formatting to PubSub files
- Remove unused using statements from PubSubMessageHandler.cs - Update lock object to use C# 13 Lock type - Apply IDE auto-formatting No functional changes, formatting only. Signed-off-by: Joe Brinkman <joe.brinkman@improving.com>
1 parent 085e548 commit 5c806cf

File tree

2 files changed

+5
-11
lines changed

2 files changed

+5
-11
lines changed

sources/Valkey.Glide/PubSubMessageHandler.cs

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

3-
using System;
4-
using System.Threading;
53

64
namespace Valkey.Glide;
75

@@ -21,7 +19,7 @@ internal sealed class PubSubMessageHandler : IDisposable
2119
private readonly MessageCallback? _callback;
2220
private readonly object? _context;
2321
private readonly PubSubMessageQueue _queue;
24-
private readonly object _lock = new();
22+
private readonly Lock _lock = new();
2523
private volatile bool _disposed;
2624

2725
/// <summary>
@@ -77,12 +75,9 @@ internal PubSubMessageQueue GetQueue()
7775
{
7876
ThrowIfDisposed();
7977

80-
if (_callback != null)
81-
{
82-
throw new InvalidOperationException("Cannot access message queue when callback is configured. Use callback mode or queue mode, not both.");
83-
}
84-
85-
return _queue;
78+
return _callback != null
79+
? throw new InvalidOperationException("Cannot access message queue when callback is configured. Use callback mode or queue mode, not both.")
80+
: _queue;
8681
}
8782

8883
/// <summary>

sources/Valkey.Glide/PubSubMessageQueue.cs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@
22

33
using System.Collections.Concurrent;
44
using System.Runtime.CompilerServices;
5-
using System.Threading;
65

76
namespace Valkey.Glide;
87

@@ -14,7 +13,7 @@ public sealed class PubSubMessageQueue : IDisposable
1413
{
1514
private readonly ConcurrentQueue<PubSubMessage> _messages;
1615
private readonly SemaphoreSlim _messageAvailable;
17-
private readonly object _lock = new();
16+
private readonly Lock _lock = new();
1817
private volatile bool _disposed;
1918

2019
/// <summary>

0 commit comments

Comments
 (0)