rsfu 0.1.1

a sfu library.
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

#[cfg(test)]
mod tests {
    use crate::buffer::factory::AtomicFactory;

    #[tokio::test]
    async fn test_factory_buffer() {
        let factory: AtomicFactory = AtomicFactory::new(1000, 1000);
        let ssrc: u32 = 123456;
        let buffer = factory.get_or_new_buffer(ssrc).await;

        const TEST_BUF: [u8; 68] = [
            0x47, 0x65, 0x6e, 0x75, 0x69, 0x6e, 0x65, 0x20, 0x41, 0x64, 0x6f, 0x62, 0x65, 0x20,
            0x46, 0x6c, 0x61, 0x73, 0x68, 0x20, 0x4d, 0x65, 0x64, 0x69, 0x61, 0x20, 0x53, 0x65,
            0x72, 0x76, 0x65, 0x72, 0x20, 0x30, 0x30,
            0x31, // Genuine Adobe Flash Media Server 001
            0xf0, 0xee, 0xc2, 0x4a, 0x80, 0x68, 0xbe, 0xe8, 0x2e, 0x00, 0xd0, 0xd1, 0x02, 0x9e,
            0x7e, 0x57, 0x6e, 0xec, 0x5d, 0x2d, 0x29, 0x80, 0x6f, 0xab, 0x93, 0xb8, 0xe6, 0x36,
            0xcf, 0xeb, 0x31, 0xae,
        ];
        let time: i64 = 1000;

        buffer.calc(&TEST_BUF, time).await;

        // let b - buffer.
    }
}