Skip to content

Commit 95c22c6

Browse files
committed
fix
1 parent c273aae commit 95c22c6

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

spring-cloud-aws-sqs/src/main/java/io/awspring/cloud/sqs/CollectionUtils.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,8 @@ public static <T> List<Collection<T>> partition(Collection<T> messagesToAck, int
2727
List<T> messagesToUse = getAsList(messagesToAck);
2828
int totalSize = messagesToUse.size();
2929
return IntStream.rangeClosed(0, (totalSize - 1) / pageSize)
30-
.mapToObj(index -> messagesToUse.subList(index * pageSize, Math.min((index + 1) * pageSize, totalSize)))
30+
.<Collection<T>> mapToObj(
31+
index -> messagesToUse.subList(index * pageSize, Math.min((index + 1) * pageSize, totalSize)))
3132
.collect(Collectors.toList());
3233
}
3334

0 commit comments

Comments
 (0)