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 156e8ad5b..e42308746 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 @@ -89,7 +89,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])); } @Override @@ -103,7 +103,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])); } @Override