Skip to content

Commit b895229

Browse files
committed
Polishing.
Avoid races in command unsubscribe fetching. See #2226
1 parent 5e23f1c commit b895229

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveSubscription.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,7 @@ public Mono<Void> pSubscribe(ByteBuffer... patterns) {
8989

9090
@Override
9191
public Mono<Void> unsubscribe() {
92-
return unsubscribe(channelState.getTargets().toArray(new ByteBuffer[channelState.getTargets().size()]));
92+
return unsubscribe(channelState.getTargets().toArray(new ByteBuffer[0]));
9393
}
9494

9595
@Override
@@ -103,7 +103,7 @@ public Mono<Void> unsubscribe(ByteBuffer... channels) {
103103

104104
@Override
105105
public Mono<Void> pUnsubscribe() {
106-
return pUnsubscribe(patternState.getTargets().toArray(new ByteBuffer[patternState.getTargets().size()]));
106+
return pUnsubscribe(patternState.getTargets().toArray(new ByteBuffer[0]));
107107
}
108108

109109
@Override

0 commit comments

Comments
 (0)