Lines Matching refs:tx
84 let tx = { in delete_allocations_by_username() localVariable
88 if let Some(tx) = tx { in delete_allocations_by_username()
90 tx.send(Command::DeleteAllocations(username, Arc::new(closed_rx))) in delete_allocations_by_username()
122 let tx = { in get_allocations_info() localVariable
126 if let Some(tx) = tx { in get_allocations_info()
128 tx.send(Command::GetAllocationsInfo(five_tuples, infos_tx)) in get_allocations_info()
133 for _ in 0..tx.receiver_count() { in get_allocations_info()
168 Ok(Command::GetAllocationsInfo(five_tuples, tx)) => { in read_loop()
170 let _ = tx.send(infos).await; in read_loop()
223 let tx = { in close() localVariable
228 if let Some(tx) = tx { in close()
229 if tx.receiver_count() == 0 { in close()
234 let _ = tx.send(Command::Close(Arc::new(closed_rx))); in close()