6 releases (3 breaking)

0.4.3 Sep 25, 2023
0.4.2 Sep 25, 2023
0.4.1 Mar 11, 2023
0.3.0 Jan 14, 2022
0.1.0 Sep 23, 2020

#103 in Video

Download history 2/week @ 2023-11-20 5/week @ 2023-11-27 13/week @ 2023-12-04 42/week @ 2023-12-11 10/week @ 2023-12-18 80/week @ 2023-12-25 30/week @ 2024-01-08 13/week @ 2024-02-05 26/week @ 2024-02-12 56/week @ 2024-02-19 33/week @ 2024-02-26 23/week @ 2024-03-04

138 downloads per month
Used in 5 crates (4 directly)

Apache-2.0

650KB
15K SLoC

Implementation of SRT in pure safe rust.

Generally used for live video streaming across lossy but high bandwidth connections.

Quick start

use srt_tokio::SrtSocket;
use futures::prelude::*;
use bytes::Bytes;
use std::time::Instant;
use std::io;

#[tokio::main]
async fn main()
{
    let sender_fut = async {
        let mut tx = SrtSocket::builder().listen_on(2223).await?;

        let iter = ["1", "2", "3"];

        tx.send_all(&mut stream::iter(&iter)
            .map(|b| Ok((Instant::now(), Bytes::from(*b))))).await?;
        tx.close().await?;

        Ok::<_, io::Error>(())
    };

    let receiver_fut = async {
        let mut rx = SrtSocket::builder().call("127.0.0.1:2223", None).await?;

        assert_eq!(rx.try_next().await?.map(|(_i, b)| b), Some(b"1"[..].into()));
        assert_eq!(rx.try_next().await?.map(|(_i, b)| b), Some(b"2"[..].into()));
        assert_eq!(rx.try_next().await?.map(|(_i, b)| b), Some(b"3"[..].into()));
        assert_eq!(rx.try_next().await?, None);

        Ok::<_, io::Error>(())
    };

    futures::try_join!(sender_fut, receiver_fut).unwrap();
}

Dependencies

~10–23MB
~323K SLoC