Load code fixed

src/data/repositories.rs

@@ -122,10 +122,10 @@ impl<T: EntityData + Clone, R: Repository<T, D>, D: DbLayer<T>> Query<T, R, D> {
         }
     }
 
-    pub fn load(&mut self, data_repository: DataRepositoryInner<T, D>) {
+    pub fn load(&mut self, data_repository: &DataRepositoryInner<T, D>) where T : Send + Sync {
         self.cache.clear();
         if self.parallel {
-            let mut cache: Vec<EntityHandle<T>> = data_repository
+            self.cache = data_repository
                 .cache
                 .par_iter()
                 .enumerate()
@@ -138,7 +138,24 @@ impl<T: EntityData + Clone, R: Repository<T, D>, D: DbLayer<T>> Query<T, R, D> {
                 })
                 .collect();
 
-            cache.extend(
+
+        }
+        else {
+            self.cache = data_repository
+                .cache
+                .iter()
+                .enumerate()
+                .filter(|(_, entity)| (self.rule)(entity))
+                .map(|(i, entity)| EntityHandle {
+                    id: entity.id(),
+                    real: true,
+                    index: i as u32,
+                    _phantom: PhantomData,
+                })
+                .collect();
+        }
+
+        self.cache.extend(
             data_repository
                 .temporal
                 .iter()
@@ -154,7 +171,6 @@ impl<T: EntityData + Clone, R: Repository<T, D>, D: DbLayer<T>> Query<T, R, D> {
         );
     }
 }
-}
 
 pub trait BatchedRepository<T, D>
 where