7 unstable releases

0.4.4 May 31, 2024
0.4.3 Sep 25, 2023
0.4.1 Mar 11, 2023
0.3.0 Jan 14, 2022
0.1.0 Sep 23, 2020

#44 in Video

Download history 33/week @ 2024-02-26 23/week @ 2024-03-04 50/week @ 2024-03-11 12/week @ 2024-03-18 68/week @ 2024-03-25 83/week @ 2024-04-01 25/week @ 2024-04-08 38/week @ 2024-04-15 50/week @ 2024-04-22 22/week @ 2024-04-29 26/week @ 2024-05-06 133/week @ 2024-05-13 94/week @ 2024-05-20 210/week @ 2024-05-27 137/week @ 2024-06-03 141/week @ 2024-06-10

598 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
~308K SLoC