Searched refs:ops_tx (Results 1 – 1 of 1) sorted by relevance
42 ops_tx: Option<Arc<mpsc::UnboundedSender<Operation>>>, field49 let (ops_tx, ops_rx) = mpsc::unbounded_channel(); in new()52 let ops_tx = Arc::new(ops_tx); in new() localVariable53 let ops_tx2 = Arc::clone(&ops_tx); in new()55 Operations::start(l, ops_tx, ops_rx, close_rx).await; in new()60 ops_tx: Some(ops_tx2), in new()68 if let Some(ops_tx) = &self.ops_tx { in enqueue()69 return Operations::enqueue_inner(op, ops_tx, &self.length); in enqueue()77 ops_tx: &Arc<mpsc::UnboundedSender<Operation>>, in enqueue_inner()81 ops_tx.send(op)?; in enqueue_inner()[all …]