jarust_core 1.4.0

A janus client SDK in Rust
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

use jarust_interface::janus_interface::JanusInterfaceImpl;
use std::time::Duration;
use tokio::time;

pub struct JaKeepAlive {
    interface: JanusInterfaceImpl,
    session_id: u64,
    ka_interval: u32,
}

impl JaKeepAlive {
    pub fn new(interface: JanusInterfaceImpl, session_id: u64, ka_interval: u32) -> Self {
        Self {
            interface,
            session_id,
            ka_interval,
        }
    }

    #[tracing::instrument(level = tracing::Level::DEBUG, skip_all, fields(session_id = self.session_id))]
    pub async fn start(&self) -> Result<(), jarust_interface::Error> {
        if !self.interface.has_keep_alive() {
            tracing::debug!("Keep-alive not supported");
            return Ok(());
        }
        let duration = Duration::from_secs(self.ka_interval.into());
        let mut interval = time::interval(duration);
        loop {
            interval.tick().await;
            tracing::debug!("Sending keep-alive");
            match self.interface.keep_alive(self.session_id, duration).await {
                Ok(_) => tracing::debug!("Keep-alive success"),
                Err(e) => tracing::error!("Keep-alive failed: {:?}", e),
            };
        }
    }
}