mediasoup 0.0.12

Cutting Edge WebRTC Video Conferencing
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

use crate::data_structures::AppData;
use crate::producer::ProducerId;
use crate::uuid_based_wrapper_type;
use crate::worker::RequestError;
use async_trait::async_trait;

uuid_based_wrapper_type!(RtpObserverId);

#[derive(Debug, Clone)]
#[non_exhaustive]
pub struct RtpObserverAddProducerOptions {
    /// The id of the Producer to be added.
    pub producer_id: ProducerId,
}

impl RtpObserverAddProducerOptions {
    pub fn new(producer_id: ProducerId) -> Self {
        Self { producer_id }
    }
}

#[async_trait(?Send)]
pub trait RtpObserver {
    /// RtpObserver id.
    fn id(&self) -> RtpObserverId;

    /// Whether the RtpObserver is paused.
    fn paused(&self) -> bool;

    /// App custom data.
    fn app_data(&self) -> &AppData;

    fn closed(&self) -> bool;

    /// Pause the RtpObserver.
    async fn pause(&self) -> Result<(), RequestError>;

    /// Resume the RtpObserver.
    async fn resume(&self) -> Result<(), RequestError>;

    /// Add a Producer to the RtpObserver.
    async fn add_producer(
        &self,
        rtp_observer_add_producer_options: RtpObserverAddProducerOptions,
    ) -> Result<(), RequestError>;

    /// Remove a Producer from the RtpObserver.
    async fn remove_producer(&self, producer_id: ProducerId) -> Result<(), RequestError>;
}