Function segment_len

crates/fs-utils/src/compression.rs:232–242

(r: &mut T)

pub use async_impls::AsyncCompressReader;

pub async fn segment_len<T: AsyncSeek + Unpin>(r: &mut T) -> tokio::io::Result<u64> {
    use tokio::io::AsyncSeekExt;
    let old_pos = r.stream_position().await?;
    let len = r.seek(tokio::io::SeekFrom::End(0)).await?;
    // If we're already at the end of the file, avoid seeking.
    if old_pos != len {
        r.seek(tokio::io::SeekFrom::Start(old_pos)).await?;
    }

    Ok(len)
}

mod async_impls {
    use super::*;