Require shard reader iter to be Send.

10XGenomics · Aug 29, 2024 · 08ace43 · 08ace43
1 parent 2da4b31
commit 08ace43
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/src/unsorted.rs b/src/unsorted.rs
@@ -42,7 +42,7 @@ where
 impl<T, S> UnsortedShardReader<T, S>
 where
     T: DeserializeOwned,
-    <S as SortKey<T>>::Key: Clone + Ord + DeserializeOwned,
+    <S as SortKey<T>>::Key: Clone + Ord + DeserializeOwned + Send,
     S: SortKey<T>,
 {
     /// Open a single shard file.
@@ -138,7 +138,7 @@ where
 impl<T, S> Iterator for UnsortedShardReader<T, S>
 where
     T: DeserializeOwned,
-    <S as SortKey<T>>::Key: Clone + Ord + DeserializeOwned,
+    <S as SortKey<T>>::Key: Clone + Ord + DeserializeOwned + Send,
     S: SortKey<T>,
 {
     type Item = Result<T, Error>;
@@ -178,15 +178,15 @@ where
     S: SortKey<T>,
 {
     count: usize,
-    file_index_iter: Box<dyn Iterator<Item = KeylessShardRecord>>,
+    file_index_iter: Box<dyn Iterator<Item = KeylessShardRecord> + Send>,
     shard_iter: Option<UnsortedShardIter<T>>,
     phantom: PhantomData<S>,
 }
 
 impl<T, S> UnsortedShardFileReader<T, S>
 where
     T: DeserializeOwned,
-    <S as SortKey<T>>::Key: Clone + Ord + DeserializeOwned,
+    <S as SortKey<T>>::Key: Clone + Ord + DeserializeOwned + Send,
     S: SortKey<T>,
 {
     /// Create a unsorted reader for a single shard file.