Struct CallRegistry 

pub struct CallRegistry { /* private fields */ }

Registry of active calls, keyed by call_sid.

Allows the inject endpoint to look up an active call and push TTS audio into it without going through the normal pipeline.

Implementations

impl CallRegistry

pub fn new() -> Self

pub async fn register( &self, call_sid: String, stream_sid: String, transport: Transport, response_tx: Sender<Message>, speaking: Arc<AtomicBool>, )

Register a new active call.

pub async fn deregister(&self, call_sid: &str)

Deregister a call when it ends.

pub async fn get(&self, call_sid: &str) -> Option<CallEntry>

Look up an active call by call_sid.

pub async fn send_audio( entry: &CallEntry, mulaw_bytes: &[u8], ) -> Result<(), Box<dyn Error + Send + Sync>>

Send mu-law audio frames into an active call.

Dispatches based on transport type:

• Twilio: wraps in JSON event envelope with base64 payload + mark event
• Discord: sends plain mu-law chunks as binary + JSON mark event

Trait Implementations

impl Clone for CallRegistry

fn clone(&self) -> CallRegistry

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for CallRegistry

fn default() -> Self

Returns the “default value” for a type.