Spring/spring-data-redis
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Polishing.

Browse Source 
Avoid races in command unsubscribe fetching.

See #2226
This commit is contained in:
Mark Paluch
2022-03-09 13:52:55 +01:00
parent 39d7c37909
commit a0b70a346c
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -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]));
}
/*