diff options
| author | Florian Klink <flokli@flokli.de> | 2024-04-12T17·51+0300 |
|---|---|---|
| committer | clbot <clbot@tvl.fyi> | 2024-04-13T10·51+0000 |
| commit | cc42cac39cce1d8991151b102eeb93752fc85e43 (patch) | |
| tree | 77a89dc32e93384353711575d505b4fe10c20a83 /tvix/castore/src | |
| parent | 820e98fa7fad2b67bd6a00af9aec068342321873 (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 'tvix/castore/src')
| -rw-r--r-- | tvix/castore/src/import.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/tvix/castore/src/import.rs b/tvix/castore/src/import.rs index 3ba6087efc29..a7034af19f5c 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 |