media-core 0.9.0

Define media types and provide basic media utilities
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
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

use media_core::audio::{circular_buffer::AudioCircularBuffer, AudioFrame, SampleFormat};

#[test]
fn test_read_write() {
    let mut audio_buf = AudioCircularBuffer::new(SampleFormat::F32P, 2, 960);

    assert_eq!(audio_buf.capacity(), 960);
    assert_eq!(audio_buf.len(), 0);
    assert_eq!(audio_buf.available(), 960);

    let mut input_frame = AudioFrame::new(SampleFormat::F32P, 2, 960, 48000).unwrap();

    if let Ok(mut guard) = input_frame.map_mut() {
        if let Some(planes) = guard.planes_mut() {
            for mut plane in planes {
                let data = plane.as_mut_slice_of::<f32>().unwrap();
                data.fill(0.5);
            }
        }
    }

    audio_buf.write(&input_frame).unwrap();
    assert_eq!(audio_buf.len(), 960);
    assert_eq!(audio_buf.available(), 0);

    let mut output_frame = AudioFrame::new(SampleFormat::F32P, 2, 240, 48000).unwrap();
    for i in 0..4 {
        assert_eq!(audio_buf.read(&mut output_frame).unwrap(), 240);
        assert_eq!(audio_buf.len(), 960 - (i + 1) * 240);
        assert_eq!(audio_buf.available(), (i + 1) * 240);

        if let Ok(guard) = output_frame.map() {
            if let Some(planes) = guard.planes() {
                for plane in planes {
                    let data = plane.as_slice_of::<f32>().unwrap();
                    for &sample in data {
                        assert_eq!(sample, 0.5);
                    }
                }
            }
        }
    }

    assert_eq!(audio_buf.len(), 0);
    assert_eq!(audio_buf.available(), 960);
}