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

DATAREDIS-647 - Polishing.

Browse Source 
Use List#toArray(T[] a) instead of Collection#stream().toArray().

Original Pull Request: #250
This commit is contained in:
Christoph Strobl
2017-06-12 13:58:24 +02:00
parent 78e5b89d1b
commit 5755ee392d
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/main/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveSetCommands.java
View File

@@ -62,7 +62,7 @@ class LettuceReactiveSetCommands implements ReactiveSetCommands {
Assert.notNull(command.getKey(), "Key must not be null!");
Assert.notNull(command.getValues(), "Values must not be null!");
return cmd.sadd(command.getKey(), command.getValues().stream().toArray(ByteBuffer[]::new))
return cmd.sadd(command.getKey(), command.getValues().toArray(new ByteBuffer[0]))
.map(value -> new NumericResponse<>(command, value));
}));
}
@@ -79,7 +79,7 @@ class LettuceReactiveSetCommands implements ReactiveSetCommands {
Assert.notNull(command.getKey(), "Key must not be null!");
Assert.notNull(command.getValues(), "Values must not be null!");
return cmd.srem(command.getKey(), command.getValues().stream().toArray(ByteBuffer[]::new))
return cmd.srem(command.getKey(), command.getValues().toArray(new ByteBuffer[0]))
.map(value -> new NumericResponse<>(command, value));
}));
}
@@ -159,7 +159,7 @@ class LettuceReactiveSetCommands implements ReactiveSetCommands {
Assert.notNull(command.getKeys(), "Keys must not be null!");
Flux<ByteBuffer> result = cmd.sinter(command.getKeys().stream().toArray(ByteBuffer[]::new));
Flux<ByteBuffer> result = cmd.sinter(command.getKeys().toArray(new ByteBuffer[0]));
return Mono.just(new CommandResponse<>(command, result));
}));
}
@@ -176,7 +176,7 @@ class LettuceReactiveSetCommands implements ReactiveSetCommands {
Assert.notNull(command.getKeys(), "Keys must not be null!");
Assert.notNull(command.getKey(), "Destination key must not be null!");
return cmd.sinterstore(command.getKey(), command.getKeys().stream().toArray(ByteBuffer[]::new))
return cmd.sinterstore(command.getKey(), command.getKeys().toArray(new ByteBuffer[0]))
.map(value -> new NumericResponse<>(command, value));
}));
}
@@ -192,7 +192,7 @@ class LettuceReactiveSetCommands implements ReactiveSetCommands {
Assert.notNull(command.getKeys(), "Keys must not be null!");
Flux<ByteBuffer> result = cmd.sunion(command.getKeys().stream().toArray(ByteBuffer[]::new));
Flux<ByteBuffer> result = cmd.sunion(command.getKeys().toArray(new ByteBuffer[0]));
return Mono.just(new CommandResponse<>(command, result));
}));
}
@@ -209,7 +209,7 @@ class LettuceReactiveSetCommands implements ReactiveSetCommands {
Assert.notNull(command.getKeys(), "Keys must not be null!");
Assert.notNull(command.getKey(), "Destination key must not be null!");
return cmd.sunionstore(command.getKey(), command.getKeys().stream().toArray(ByteBuffer[]::new))
return cmd.sunionstore(command.getKey(), command.getKeys().toArray(new ByteBuffer[0]))
.map(value -> new NumericResponse<>(command, value));
}));
}
@@ -225,7 +225,7 @@ class LettuceReactiveSetCommands implements ReactiveSetCommands {
Assert.notNull(command.getKeys(), "Keys must not be null!");
Flux<ByteBuffer> result = cmd.sdiff(command.getKeys().stream().toArray(ByteBuffer[]::new));
Flux<ByteBuffer> result = cmd.sdiff(command.getKeys().toArray(new ByteBuffer[0]));
return Mono.just(new CommandResponse<>(command, result));
}));
}
@@ -242,7 +242,7 @@ class LettuceReactiveSetCommands implements ReactiveSetCommands {
Assert.notNull(command.getKeys(), "Keys must not be null!");
Assert.notNull(command.getKey(), "Destination key must not be null!");
return cmd.sdiffstore(command.getKey(), command.getKeys().stream().toArray(ByteBuffer[]::new))
return cmd.sdiffstore(command.getKey(), command.getKeys().toArray(new ByteBuffer[0]))
.map(value -> new NumericResponse<>(command, value));
}));
}