oximedia-container 0.1.5

Container demuxer/muxer for OxiMedia
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

//! Utility functions for metadata operations.

use async_trait::async_trait;
use oximedia_core::{OxiError, OxiResult};
use oximedia_io::MediaSource;

/// Extension trait for reading exact number of bytes.
#[async_trait]
pub(crate) trait MediaSourceExt {
    /// Reads exactly `buf.len()` bytes.
    async fn read_exact(&mut self, buf: &mut [u8]) -> OxiResult<()>;
}

#[async_trait]
impl<T: MediaSource> MediaSourceExt for T {
    async fn read_exact(&mut self, buf: &mut [u8]) -> OxiResult<()> {
        let mut offset = 0;
        while offset < buf.len() {
            let n = self.read(&mut buf[offset..]).await?;
            if n == 0 {
                return Err(OxiError::UnexpectedEof);
            }
            offset += n;
        }
        Ok(())
    }
}