diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveSubscription.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveSubscription.java index 4ff5313c3..d9cbe29fe 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveSubscription.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveSubscription.java @@ -101,7 +101,7 @@ class LettuceReactiveSubscription implements ReactiveSubscription { */ @Override public Mono unsubscribe() { - return unsubscribe(channelState.getTargets().toArray(new ByteBuffer[channelState.getTargets().size()])); + return unsubscribe(channelState.getTargets().toArray(new ByteBuffer[0])); } /* @@ -123,7 +123,7 @@ class LettuceReactiveSubscription implements ReactiveSubscription { */ @Override public Mono pUnsubscribe() { - return pUnsubscribe(patternState.getTargets().toArray(new ByteBuffer[patternState.getTargets().size()])); + return pUnsubscribe(patternState.getTargets().toArray(new ByteBuffer[0])); } /*