Struct RealtimeSession 

pub struct RealtimeSession {
    pub id: String,
    /* private fields */
}

Real-time audio session

Fields

id: String

Session ID

Implementations

impl RealtimeSession

pub async fn send_event(&self, event: RealtimeEvent) -> Result<()>

Send an event to the server

pub async fn send_audio(&self, audio_buffer: AudioBuffer) -> Result<()>

Send audio data

pub async fn start_audio_input(&self) -> Result<()>

Start audio streaming from microphone

pub async fn stop_audio_input(&self) -> Result<()>

Stop audio streaming

pub async fn handle_data_channel_message( &self, msg: DataChannelMessage, ) -> Result<()>

Handle incoming data channel message

pub async fn handle_incoming_track(&self, track: Arc<TrackRemote>)

Handle incoming audio track

impl RealtimeSession

pub fn new( id: String, peer_connection: Arc<RTCPeerConnection>, event_sender: UnboundedSender<RealtimeEvent>, event_receiver: UnboundedReceiver<RealtimeEvent>, audio_sender: UnboundedSender<AudioBuffer>, audio_receiver: UnboundedReceiver<AudioBuffer>, config: RealtimeSessionConfig, vad: VoiceActivityDetector, ) -> Self

Create a new realtime session

pub async fn event_stream(&self) -> Option<UnboundedReceiver<RealtimeEvent>>

Get event stream

pub async fn audio_stream(&self) -> Option<UnboundedReceiver<AudioBuffer>>

Get audio stream

pub async fn get_stats(&self) -> WebRtcStats

Get session statistics

pub fn is_active(&self) -> bool

Check if session is active

pub fn started_at(&self) -> DateTime<Utc>

Get session start time

pub async fn close(&self) -> Result<()>

Close the session

pub async fn set_data_channel(&self, data_channel: Arc<RTCDataChannel>)

Set the data channel

pub async fn set_audio_track(&self, audio_track: Arc<TrackLocalStaticSample>)

Set the audio track

pub async fn connection_state(&self) -> WebRtcConnectionState

Get the connection state

pub async fn set_connection_state(&self, state: WebRtcConnectionState)

Set the connection state

pub fn peer_connection(&self) -> &Arc<RTCPeerConnection>

Get the peer connection