Searched refs:command_tx (Results 1 – 1 of 1) sorted by relevance
35 command_tx: Mutex<Option<broadcast::Sender<Command>>>, field43 let (command_tx, _) = broadcast::channel(16); in new()49 command_tx: Mutex::new(Some(command_tx.clone())), in new()61 let handle_rx = command_tx.subscribe(); in new()85 let command_tx = self.command_tx.lock().await; in delete_allocations_by_username() localVariable86 command_tx.clone() in delete_allocations_by_username()123 let command_tx = self.command_tx.lock().await; in get_allocations_info() localVariable124 command_tx.clone() in get_allocations_info()224 let mut command_tx = self.command_tx.lock().await; in close() localVariable225 command_tx.take() in close()