This commit is contained in:
Ferdinand Schober
2024-11-08 17:20:32 +01:00
parent ef2b2a773e
commit d30bd81fa9

View File

@@ -198,9 +198,6 @@ impl CaptureTask {
if let Err(e) = self.do_capture().await { if let Err(e) = self.do_capture().await {
log::warn!("input capture exited: {e}"); log::warn!("input capture exited: {e}");
} }
if self.cancellation_token.is_cancelled() {
break;
}
loop { loop {
tokio::select! { tokio::select! {
r = self.request_rx.recv() => match r.expect("channel closed") { r = self.request_rx.recv() => match r.expect("channel closed") {
@@ -209,7 +206,7 @@ impl CaptureTask {
CaptureRequest::Destroy(h) => self.remove_capture(h), CaptureRequest::Destroy(h) => self.remove_capture(h),
CaptureRequest::Release => { /* nothing to do */ } CaptureRequest::Release => { /* nothing to do */ }
}, },
_ = self.cancellation_token.cancelled() => break, _ = self.cancellation_token.cancelled() => return,
} }
} }
} }