Searched refs:wait_group (Results 1 – 4 of 4) sorted by relevance
110 let wait_group = self.wg.lock().await; in bind_rtcp_writer() localVariable111 wait_group.as_ref().map(|wg| wg.worker()) in bind_rtcp_writer()173 let mut wait_group = self.wg.lock().await; in close() localVariable174 if let Some(wg) = wait_group.take() { in close()
152 let wait_group = self.wg.lock().await; in bind_rtcp_writer() localVariable153 wait_group.as_ref().map(|wg| wg.worker()) in bind_rtcp_writer()215 let mut wait_group = self.wg.lock().await; in close() localVariable216 if let Some(wg) = wait_group.take() { in close()
186 let wait_group = self.wg.lock().await; in bind_rtcp_writer() localVariable187 wait_group.as_ref().map(|wg| wg.worker()) in bind_rtcp_writer()251 let mut wait_group = self.wg.lock().await; in close() localVariable252 if let Some(wg) = wait_group.take() { in close()
176 let wait_group = self.wg.lock().await; in bind_rtcp_writer() localVariable177 wait_group.as_ref().map(|wg| wg.worker()) in bind_rtcp_writer()253 let mut wait_group = self.wg.lock().await; in close() localVariable254 if let Some(wg) = wait_group.take() { in close()