librtmp2 0.1.0

librtmp2 — RTMP/RTMPS protocol 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
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53

//! Minimal RTMP client: connects, publishes a stream, and sends a single
//! synthetic video frame. Rust port of the old
//! `examples/minimal_client/minimal_client.c`.
//!
//! Usage: minimal_client rtmp://host:port/app/stream

use std::env;
use std::process::ExitCode;

use librtmp2::client::Client;
use librtmp2::types::*;

fn main() -> ExitCode {
    let Some(url) = env::args().nth(1) else {
        eprintln!("Usage: minimal_client rtmp://host:port/app/stream");
        return ExitCode::FAILURE;
    };

    println!("[minimal_client] librtmp2 v{VERSION_STRING}");
    println!("[minimal_client] Connecting to {url}");

    let mut client = Client::new();
    if let Err(e) = client.connect(&url) {
        eprintln!("Failed to connect: {e:?}");
        return ExitCode::FAILURE;
    }
    println!("[minimal_client] Connected");

    if let Err(e) = client.publish() {
        eprintln!("Failed to publish: {e:?}");
        return ExitCode::FAILURE;
    }
    println!("[minimal_client] Publishing");

    let payload = [0xABu8; 64];
    let frame = Frame {
        frame_type: FrameType::Video,
        timestamp: 0,
        size: payload.len() as u32,
        data: payload.as_ptr(),
        video_codec: VideoCodec::H264,
        video_frame_type: 1, // keyframe
        ..Default::default()
    };

    if let Err(e) = client.send_frame(&frame) {
        eprintln!("Failed to send frame: {e:?}");
        return ExitCode::FAILURE;
    }
    println!("[minimal_client] Sent {}-byte video frame", frame.size);

    ExitCode::SUCCESS
}