From b895229f7cbf25ccfed41a7d317ae6d91d7f377d Mon Sep 17 00:00:00 2001
From: Mark Paluch <mpaluch@vmware.com>
Date: Wed, 9 Mar 2022 13:52:55 +0100
Subject: [PATCH] Polishing.

Avoid races in command unsubscribe fetching.

See #2226
---
 .../redis/connection/lettuce/LettuceReactiveSubscription.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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<Void> 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<Void> pUnsubscribe() {
-		return pUnsubscribe(patternState.getTargets().toArray(new ByteBuffer[patternState.getTargets().size()]));
+		return pUnsubscribe(patternState.getTargets().toArray(new ByteBuffer[0]));
 	}
 
 	@Override