diff --git a/cohereflux-core/src/main/java/io/github/pellse/cohereflux/caching/CacheFactory.java b/cohereflux-core/src/main/java/io/github/pellse/cohereflux/caching/CacheFactory.java
index 759658bd..a66582eb 100644
--- a/cohereflux-core/src/main/java/io/github/pellse/cohereflux/caching/CacheFactory.java
+++ b/cohereflux-core/src/main/java/io/github/pellse/cohereflux/caching/CacheFactory.java
@@ -22,6 +22,7 @@
 import io.github.pellse.util.collection.CollectionUtils;
 import org.reactivestreams.Publisher;
 import reactor.core.publisher.Mono;
+import reactor.core.scheduler.Schedulers;
 
 import java.util.*;
 import java.util.function.BiFunction;
@@ -130,6 +131,7 @@ static <T, TC extends Collection<T>, ID, EID, R, RRC> RuleMapperSource<T, TC, ID
                     .create(new CacheContext<>(isEmptySource, ruleContext));
 
             return entities -> cache.getAll(ids(entities, ruleContext), isEmptySource ? ids ->  just(of()) : buildFetchFunction(entities, ruleContext, queryFunction))
+                    .subscribeOn(Schedulers.boundedElastic())
                     .filter(CollectionUtils::isNotEmpty)
                     .flatMapMany(map -> fromStream(map.values().stream().flatMap(Collection::stream)))
                     .onErrorResume(not(QueryFunctionException.class::isInstance), __ -> queryFunction.apply(entities))