Searched refs:ClientAgent (Results 1 – 2 of 2) sorted by relevance
| /webrtc/stun/src/ |
| H A D | agent.rs | 107 pub enum ClientAgent { enum
265 pub(crate) async fn run(mut agent: Agent, mut rx: mpsc::Receiver<ClientAgent>) { in run() argument
268 ClientAgent::Process(message) => agent.process(message), in run()
269 ClientAgent::Collect(deadline) => agent.collect(deadline), in run()
270 ClientAgent::Start(tid, deadline) => agent.start(tid, deadline), in run()
271 ClientAgent::Stop(tid) => agent.stop(tid), in run()
272 ClientAgent::Close => agent.close(), in run()
|
| H A D | client.rs | 30 client_agent_tx: Arc<mpsc::Sender<ClientAgent>>, in start() argument
44 client_agent_tx: Arc<mpsc::Sender<ClientAgent>>, in start() argument
56 … if client_agent_tx.send(ClientAgent::Collect(Instant::now())).await.is_err() { in start()
216 client_agent_tx: Option<Arc<mpsc::Sender<ClientAgent>>>,
224 client_agent_tx: Arc<mpsc::Sender<ClientAgent>>, in read_until_closed() argument
282 client_agent_tx: Arc<mpsc::Sender<ClientAgent>>, in start() argument
330 .send(ClientAgent::Start(id, timeout)) in start()
344 let _ = client_agent_tx.send(ClientAgent::Stop(id)).await; in start()
374 let _ = client_agent_tx.send(ClientAgent::Close).await; in close()
451 .send(ClientAgent::Start(m.transaction_id, d)) in send()
[all …]
|