From cc42cac39cce1d8991151b102eeb93752fc85e43 Mon Sep 17 00:00:00 2001 From: Florian Klink Date: Fri, 12 Apr 2024 20:51:15 +0300 Subject: [PATCH] refactor(tvix/castore/import): rename ingest_entries function arg 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 Autosubmit: flokli Tested-by: BuildkiteCI --- tvix/castore/src/import.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/tvix/castore/src/import.rs b/tvix/castore/src/import.rs index 3ba6087ef..a7034af19 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 where BS: AsRef + 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