From d4aee348ef192039a0e8de7fd8cc61e00333ea0b Mon Sep 17 00:00:00 2001
From: ggivo <ivo.gaydazhiev@redis.com>
Date: Thu, 24 Oct 2024 09:19:19 +0300
Subject: [PATCH] Formatiing

---
 .../pubsub/StatefulRedisPubSubConnectionImplUnitTests.java | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/src/test/java/io/lettuce/core/pubsub/StatefulRedisPubSubConnectionImplUnitTests.java b/src/test/java/io/lettuce/core/pubsub/StatefulRedisPubSubConnectionImplUnitTests.java
index 769f93f5d..9eb552824 100644
--- a/src/test/java/io/lettuce/core/pubsub/StatefulRedisPubSubConnectionImplUnitTests.java
+++ b/src/test/java/io/lettuce/core/pubsub/StatefulRedisPubSubConnectionImplUnitTests.java
@@ -93,7 +93,8 @@ void resubscribeChannelSubscription() {
     @Test
     void resubscribeShardChannelSubscription() {
         when(mockedEndpoint.hasShardChannelSubscriptions()).thenReturn(true);
-        when(mockedEndpoint.getShardChannels()).thenReturn(new HashSet<>(Arrays.asList(new String[] { "shard_channel1", "shard_channel2" })));
+        when(mockedEndpoint.getShardChannels())
+                .thenReturn(new HashSet<>(Arrays.asList(new String[] { "shard_channel1", "shard_channel2" })));
         when(mockedEndpoint.hasChannelSubscriptions()).thenReturn(false);
         when(mockedEndpoint.hasPatternSubscriptions()).thenReturn(false);
 
@@ -104,7 +105,6 @@ void resubscribeShardChannelSubscription() {
         assertInstanceOf(AsyncCommand.class, commandFuture);
     }
 
-
     @Test
     void resubscribeChannelAndPatternAndShardChanelSubscription() {
         when(mockedEndpoint.hasChannelSubscriptions()).thenReturn(true);
@@ -112,7 +112,8 @@ void resubscribeChannelAndPatternAndShardChanelSubscription() {
         when(mockedEndpoint.hasShardChannelSubscriptions()).thenReturn(true);
         when(mockedEndpoint.getChannels()).thenReturn(new HashSet<>(Arrays.asList(new String[] { "channel1", "channel2" })));
         when(mockedEndpoint.getPatterns()).thenReturn(new HashSet<>(Arrays.asList(new String[] { "bcast*", "echo" })));
-        when(mockedEndpoint.getShardChannels()).thenReturn(new HashSet<>(Arrays.asList(new String[] { "shard_channel1", "shard_channel2" })));
+        when(mockedEndpoint.getShardChannels())
+                .thenReturn(new HashSet<>(Arrays.asList(new String[] { "shard_channel1", "shard_channel2" })));
         List<RedisFuture<Void>> subscriptions = connection.resubscribe();
 
         assertEquals(3, subscriptions.size());