Method decode_streamed

crates/runner-shared/src/artifacts/memtrack.rs:21–28

(
        reader: R,
    )

impl MemtrackArtifact {
    pub fn decode_streamed<R: std::io::Read>(
        reader: R,
    ) -> anyhow::Result<MemtrackEventStream<zstd::Decoder<'static, std::io::BufReader<R>>>> {
        let decoder = zstd::Decoder::new(reader)?;
        Ok(MemtrackEventStream {
            deserializer: rmp_serde::Deserializer::new(decoder),
        })
    }

    pub fn is_empty<R: std::io::Read>(reader: R) -> bool {
        let Ok(mut stream) = MemtrackArtifact::decode_streamed(BufReader::new(reader)) else {