pub async fn get_receiver(session_id: &str) -> Option<Receiver<String>>
Get a session’s receiver for SSE streaming