Toggle navigation
Home
java.util.Optional<java.lang.Integer> to org.apache.james.mailbox.cassandra.Limit
No. of Instances - 1
No. of Commits - 1
No. of Projects - {'james-project'}
Hierarchy/Composition: Composition
Primitive Info: -
NameSpace: Jdk -> Internal
Mapping:
Add or Remove Method invocation
CompletableFutureUtil.chainAll(getLimitedIdStream(messageIds.stream().distinct(),limit).collect(JamesCollectors.chunker(cassandraConfiguration.getMessageReadChunkSize())),ids -> FluentFutureStream.of(ids.stream().map(id -> retrieveRow(id,fetchType).thenApply((ResultSet resultSet) -> message(resultSet.one(),id,fetchType)))).completableFuture())
to
CompletableFutureUtil.chainAll(limit.applyOnStream(messageIds.stream().distinct()).collect(JamesCollectors.chunker(cassandraConfiguration.getMessageReadChunkSize())),ids -> FluentFutureStream.of(ids.stream().map(id -> retrieveRow(id,fetchType).thenApply((ResultSet resultSet) -> message(resultSet.one(),id,fetchType)))).completableFuture())