Searched refs:Operation (Results 1 – 3 of 3) sorted by relevance
15 pub struct Operation( struct20 impl Operation { implementation29 impl fmt::Debug for Operation { implementation42 ops_tx: Option<Arc<mpsc::UnboundedSender<Operation>>>,67 pub(crate) async fn enqueue(&self, op: Operation) -> Result<()> { in enqueue()76 op: Operation, in enqueue_inner() argument77 ops_tx: &Arc<mpsc::UnboundedSender<Operation>>, in enqueue_inner() argument97 .enqueue(Operation::new( in done()110 ops_tx: Arc<mpsc::UnboundedSender<Operation>>, in start() argument111 mut ops_rx: mpsc::UnboundedReceiver<Operation>, in start() argument
13 ops.enqueue(Operation::new( in test_operations_enqueue()
45 use crate::peer_connection::operation::{Operation, Operations};351 .enqueue(Operation::new( in do_negotiation_needed()1266 .enqueue(Operation::new( in set_local_description()1502 .enqueue(Operation::new( in set_remote_description()1553 .enqueue(Operation::new( in set_remote_description()