(
&mut self,
entries: impl rayon::iter::IntoParallelIterator<Item = (String, impl AsRef<[u8]>)>,
)
| 96 | } |
| 97 | |
| 98 | fn put_par( |
| 99 | &mut self, |
| 100 | entries: impl rayon::iter::IntoParallelIterator<Item = (String, impl AsRef<[u8]>)>, |
| 101 | ) -> Result<()> { |
| 102 | let prefix = self.prefix; |
| 103 | let prefixed: Vec<(String, Vec<u8>)> = entries |
| 104 | .into_par_iter() |
| 105 | .map(move |(key, value)| (format!("{}/{}", prefix, key), value.as_ref().to_vec())) |
| 106 | .collect(); |
| 107 | self.inner.put_par(prefixed) |
| 108 | } |
| 109 | } |
| 110 | |
| 111 | impl<R: OdbReader> OdbReader for PrefixedReader<'_, R> { |