Skip to content

Commit

Permalink
Fix up code style
Browse files Browse the repository at this point in the history
  • Loading branch information
NickCraver committed Aug 18, 2024
1 parent 8c40850 commit 054b5c4
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 5 deletions.
4 changes: 2 additions & 2 deletions src/StackExchange.Redis/RedisSubscriber.cs
Original file line number Diff line number Diff line change
Expand Up @@ -207,7 +207,7 @@ public void Add(Action<RedisChannel, RedisValue>? handler, ChannelMessageQueue?
{
if (handler != null)
{
lock(_handlersLock)
lock (_handlersLock)
{
_handlers += handler;
}
Expand Down Expand Up @@ -243,7 +243,7 @@ public bool Remove(Action<RedisChannel, RedisValue>? handler, ChannelMessageQueu

internal void MarkCompleted()
{
lock(_handlersLock)
lock (_handlersLock)
{
_handlers = null;
}
Expand Down
6 changes: 3 additions & 3 deletions tests/StackExchange.Redis.Tests/Issues/Issue2763Tests.cs
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ public void Execute()
using var conn = Create();
var subscriber = conn.GetSubscriber();

void Handler(RedisChannel c, RedisValue v) { }
static void Handler(RedisChannel c, RedisValue v) { }

const int COUNT = 1000;
RedisChannel channel = RedisChannel.Literal("CHANNEL:TEST");
Expand All @@ -36,10 +36,10 @@ void Handler(RedisChannel c, RedisValue v) { }
Assert.Equal(0, CountSubscriptionsForChannel(subscriber, channel));
}

private int CountSubscriptionsForChannel(ISubscriber subscriber, RedisChannel channel)
private static int CountSubscriptionsForChannel(ISubscriber subscriber, RedisChannel channel)
{
ConnectionMultiplexer connMultiplexer = (ConnectionMultiplexer)subscriber.Multiplexer;
connMultiplexer.GetSubscriberCounts(channel, out int handlers, out int queues);
connMultiplexer.GetSubscriberCounts(channel, out int handlers, out int _);
return handlers;
}
}
Expand Down

0 comments on commit 054b5c4

Please sign in to comment.