rvoip-rtp-core 0.2.4

RTP/RTCP protocol implementation for the rvoip stack
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
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107

//! TCP transport for RTP/RTCP
//!
//! This module provides a TCP transport for RTP and RTCP.
//! Currently, this is a placeholder for future implementation.

use std::any::Any;
use std::net::SocketAddr;
use tokio::sync::broadcast;

use super::{RtpTransport, RtpTransportConfig};
use crate::error::Error;
use crate::traits::RtpEvent;
use crate::Result;

/// TCP transport for RTP (placeholder)
#[allow(dead_code)] // retained (liveness/Drop hold or reserved); not read
pub struct TcpRtpTransport {
    /// Configuration
    #[allow(dead_code)] // retained (liveness/Drop hold or reserved); not read
    config: RtpTransportConfig,

    /// Event channel
    event_tx: broadcast::Sender<RtpEvent>,
}

impl TcpRtpTransport {
    /// Create a new TCP transport (placeholder)
    pub async fn new(_config: RtpTransportConfig) -> Result<Self> {
        let (event_tx, _) = broadcast::channel(100);

        Ok(Self {
            config: _config,
            event_tx,
        })
    }
}

#[async_trait::async_trait]
impl RtpTransport for TcpRtpTransport {
    /// Get the local RTP address
    fn local_rtp_addr(&self) -> Result<SocketAddr> {
        Err(Error::NotImplemented(
            "TCP transport not yet implemented".to_string(),
        ))
    }

    /// Get the local RTCP address
    fn local_rtcp_addr(&self) -> Result<Option<SocketAddr>> {
        Err(Error::NotImplemented(
            "TCP transport not yet implemented".to_string(),
        ))
    }

    /// Send an RTP packet
    async fn send_rtp(&self, _packet: &crate::packet::RtpPacket, _dest: SocketAddr) -> Result<()> {
        Err(Error::NotImplemented(
            "TCP transport not yet implemented".to_string(),
        ))
    }

    /// Send RTP bytes
    async fn send_rtp_bytes(&self, _bytes: &[u8], _dest: SocketAddr) -> Result<()> {
        Err(Error::NotImplemented(
            "TCP transport not yet implemented".to_string(),
        ))
    }

    /// Send RTCP data
    async fn send_rtcp_bytes(&self, _data: &[u8], _dest: SocketAddr) -> Result<()> {
        Err(Error::NotImplemented(
            "TCP transport not yet implemented".to_string(),
        ))
    }

    /// Send an RTCP packet
    async fn send_rtcp(
        &self,
        _packet: &crate::packet::rtcp::RtcpPacket,
        _dest: SocketAddr,
    ) -> Result<()> {
        Err(Error::NotImplemented(
            "TCP transport not yet implemented".to_string(),
        ))
    }

    /// Receive a packet
    async fn receive_packet(&self, _buffer: &mut [u8]) -> Result<(usize, SocketAddr)> {
        Err(Error::NotImplemented(
            "TCP transport not yet implemented".to_string(),
        ))
    }

    /// Close the transport
    async fn close(&self) -> Result<()> {
        Ok(())
    }

    /// Subscribe to transport events
    fn subscribe(&self) -> broadcast::Receiver<RtpEvent> {
        self.event_tx.subscribe()
    }

    /// Get the transport as Any (for downcasting)
    fn as_any(&self) -> &dyn Any {
        self
    }
}