Polishing

redis · May 21, 2024 · 8b59ebd · 8b59ebd
1 parent 4e8a93a
commit 8b59ebd
Show file tree

Hide file tree

Showing 3 changed files with 17 additions and 12 deletions.
diff --git a/src/main/java/io/lettuce/core/output/IntegerListOutput.java b/src/main/java/io/lettuce/core/output/IntegerListOutput.java
@@ -31,7 +31,9 @@ public void set(long integer) {
         subscriber.onNext(output, integer);
     }
 
+    @Override
     public void set(ByteBuffer bytes) {
+        // ignore empty ByteBuffer, would fail otherwise
         if (bytes != null) {
             super.set(bytes);
         }

diff --git a/...io/lettuce/core/cluster/commands/reactive/HashClusterReactiveCommandIntegrationTests.java b/...io/lettuce/core/cluster/commands/reactive/HashClusterReactiveCommandIntegrationTests.java
@@ -1,12 +1,13 @@
 package io.lettuce.core.cluster.commands.reactive;
 
-import io.lettuce.core.cluster.api.StatefulRedisClusterConnection;
-import io.lettuce.core.commands.HashCommandIntegrationTests;
-import io.lettuce.test.ReactiveSyncInvocationHandler;
+import javax.inject.Inject;
+
 import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 
-import javax.inject.Inject;
+import io.lettuce.core.cluster.api.StatefulRedisClusterConnection;
+import io.lettuce.core.commands.HashCommandIntegrationTests;
+import io.lettuce.test.ReactiveSyncInvocationHandler;
 
 /**
  * @author Mark Paluch

diff --git a/src/test/java/io/lettuce/core/commands/reactive/HashReactiveCommandIntegrationTests.java b/src/test/java/io/lettuce/core/commands/reactive/HashReactiveCommandIntegrationTests.java
@@ -1,18 +1,20 @@
 package io.lettuce.core.commands.reactive;
 
+import static org.assertj.core.api.Assertions.assertThat;
+
+import java.util.stream.Collectors;
+
+import javax.inject.Inject;
+
+import org.junit.jupiter.api.Disabled;
+import org.junit.jupiter.api.Test;
+
+import reactor.test.StepVerifier;
 import io.lettuce.core.KeyValue;
 import io.lettuce.core.Value;
 import io.lettuce.core.api.StatefulRedisConnection;
 import io.lettuce.core.commands.HashCommandIntegrationTests;
 import io.lettuce.test.ReactiveSyncInvocationHandler;
-import org.junit.jupiter.api.Disabled;
-import org.junit.jupiter.api.Test;
-import reactor.test.StepVerifier;
-
-import javax.inject.Inject;
-import java.util.stream.Collectors;
-
-import static org.assertj.core.api.Assertions.assertThat;
 
 /**
  * x