From 81a64e8c69ad923760154c2f5162b41a591efdbf Mon Sep 17 00:00:00 2001 From: Xiaobo Liu Date: Sun, 10 Aug 2025 19:16:25 +0800 Subject: [PATCH] interceptor: simplify NACK generator close_rx error handling Signed-off-by: Xiaobo Liu --- interceptor/src/nack/generator/mod.rs | 14 ++++++-------- 1 file changed, 6 insertions(+), 8 deletions(-) diff --git a/interceptor/src/nack/generator/mod.rs b/interceptor/src/nack/generator/mod.rs index 7780b237a..16b665879 100644 --- a/interceptor/src/nack/generator/mod.rs +++ b/interceptor/src/nack/generator/mod.rs @@ -107,14 +107,12 @@ impl Generator { internal: Arc, ) -> Result<()> { let mut ticker = tokio::time::interval(internal.interval); - let mut close_rx = { - let mut close_rx = internal.close_rx.lock().await; - if let Some(close) = close_rx.take() { - close - } else { - return Err(Error::ErrInvalidCloseRx); - } - }; + let mut close_rx = internal + .close_rx + .lock() + .await + .take() + .ok_or(Error::ErrInvalidCloseRx)?; let sender_ssrc = rand::random::(); loop {