We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent dec7b58 commit 37f0e0eCopy full SHA for 37f0e0e
interceptor/src/nack/generator/mod.rs
@@ -107,14 +107,12 @@ impl Generator {
107
internal: Arc<GeneratorInternal>,
108
) -> Result<()> {
109
let mut ticker = tokio::time::interval(internal.interval);
110
- let mut close_rx = {
111
- let mut close_rx = internal.close_rx.lock().await;
112
- if let Some(close) = close_rx.take() {
113
- close
114
- } else {
115
- return Err(Error::ErrInvalidCloseRx);
116
- }
117
- };
+ let mut close_rx = internal
+ .close_rx
+ .lock()
+ .await
+ .take()
+ .ok_or(Error::ErrInvalidCloseRx)?;
118
119
let sender_ssrc = rand::random::<u32>();
120
loop {
0 commit comments