about summary refs log tree commit diff
path: root/tvix/castore/src/import.rs
diff options
context:
space:
mode:
authorFlorian Klink <flokli@flokli.de>2024-04-12T17·51+0300
committerclbot <clbot@tvl.fyi>2024-04-13T10·51+0000
commitcc42cac39cce1d8991151b102eeb93752fc85e43 (patch)
tree77a89dc32e93384353711575d505b4fe10c20a83 /tvix/castore/src/import.rs
parent820e98fa7fad2b67bd6a00af9aec068342321873 (diff)
refactor(tvix/castore/import): rename ingest_entries function arg r/7902
This is a stream of DirEntry, so let's call it direntry_stream.

Change-Id: I5b3cb4efba899d746393f75f6ece7eaa79424717
Reviewed-on: https://cl.tvl.fyi/c/depot/+/11401
Reviewed-by: raitobezarius <tvl@lahfa.xyz>
Autosubmit: flokli <flokli@flokli.de>
Tested-by: BuildkiteCI
Diffstat (limited to '')
-rw-r--r--tvix/castore/src/import.rs4
1 files changed, 2 insertions, 2 deletions
diff --git a/tvix/castore/src/import.rs b/tvix/castore/src/import.rs
index 3ba6087efc..a7034af19f 100644
--- a/tvix/castore/src/import.rs
+++ b/tvix/castore/src/import.rs
@@ -302,7 +302,7 @@ impl MerkleInvariantChecker {
 pub async fn ingest_entries<'a, BS, DS, S>(
     blob_service: BS,
     directory_service: DS,
-    mut entries_async_iterator: S,
+    mut direntry_stream: S,
 ) -> Result<Node, Error>
 where
     BS: AsRef<dyn BlobService> + Clone,
@@ -319,7 +319,7 @@ where
     // We need to process a directory's children before processing
     // the directory itself in order to have all the data needed
     // to compute the hash.
-    while let Some(entry) = entries_async_iterator.next().await {
+    while let Some(entry) = direntry_stream.next().await {
         #[cfg(debug_assertions)]
         {
             // If we find an ancestor before we see this entry, this means that the caller