Skip to content

Commit

Permalink
revert comments
Browse files Browse the repository at this point in the history
Signed-off-by: Pavel Jareš <[email protected]>
  • Loading branch information
pj892031 committed Sep 25, 2023
1 parent 5de0040 commit 0531ec2
Showing 1 changed file with 2 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -66,6 +66,8 @@ public void evictSubset(CacheManager cacheManager, String cacheName, Predicate<C
if (nativeCache instanceof javax.cache.Cache) {
Spliterator<javax.cache.Cache.Entry<Object, Object>> spliterator = ((javax.cache.Cache<Object, Object>) nativeCache).spliterator();
Set<Object> keysToRemove = StreamSupport.stream(spliterator, true)
// if entry is compositeKey and first param is the same filter it to be removed or
// if key is not composite key (unknown for evict) evict record (as failover)
.filter(e -> !(e.getKey() instanceof CompositeKey) || keyPredicate.test((CompositeKey) e.getKey()))
.map(javax.cache.Cache.Entry::getKey)
.collect(Collectors.toSet());
Expand Down

0 comments on commit 0531ec2

Please sign in to comment.