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