Start9/start-os
2
0
Fork 0
mirror of https://github.com/Start9Labs/start-os.git synced 2026-03-31 04:23:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: Cleaning up the stream to a regular stream (#2468)

Browse Source
This commit is contained in:
J H
2023-10-23 14:41:54 -06:00
committed by GitHub
parent 8ea3c3c29e
commit a69cae22dd
1 changed files with 6 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
backend/src/procedure/docker.rs
View File

@@ -892,22 +892,13 @@ async fn buf_reader_to_lines(
reader: impl AsyncBufRead + Unpin, reader: impl AsyncBufRead + Unpin,
limit: impl Into<Option<usize>>, limit: impl Into<Option<usize>>,
) -> Result<Vec<String>, Error> { ) -> Result<Vec<String>, Error> {
let lines = stream! { let mut lines = reader.lines();
let mut lines = reader.lines(); let mut output = RingVec::new(limit.into().unwrap_or(1000));
while let Some(line) = lines.next_line().await? { while let Ok(line) = lines.next_line().await {
yield Ok::<_, Report>(line); if let Some(line) = line {
output.push(line);
} }
}; }
let output: RingVec<String> = lines
.try_fold(
RingVec::new(limit.into().unwrap_or(1000)),
|mut acc, line| async move {
acc.push(line);
Ok(acc)
},
)
.await
.with_kind(crate::ErrorKind::Unknown)?;
let output: Vec<String> = output.value.into_iter().collect(); let output: Vec<String> = output.value.into_iter().collect();
Ok(output) Ok(output)
} }