diff --git a/codex-rs/core/tests/common/Cargo.toml b/codex-rs/core/tests/common/Cargo.toml
index 75fdc8790f..026be6d388 100644
--- a/codex-rs/core/tests/common/Cargo.toml
+++ b/codex-rs/core/tests/common/Cargo.toml
@@ -47,7 +47,3 @@ zstd = { workspace = true }
 [dev-dependencies]
 pretty_assertions = { workspace = true }
 reqwest = { workspace = true }
-
-[package.metadata.cargo-shear]
-# Imported as `audiopus` from Rust code, but declared as `opus` in workspace deps.
-ignored = ["opus"]
diff --git a/codex-rs/core/tests/common/responses/realtime_webrtc_server.rs b/codex-rs/core/tests/common/responses/realtime_webrtc_server.rs
index d9315f90b6..d1881b41a7 100644
--- a/codex-rs/core/tests/common/responses/realtime_webrtc_server.rs
+++ b/codex-rs/core/tests/common/responses/realtime_webrtc_server.rs
@@ -3,10 +3,10 @@ use std::sync::Arc;
 use std::sync::Mutex;
 use std::time::Duration;
 
-use audiopus::Channels;
-use audiopus::coder::Decoder as OpusDecoder;
 use base64::Engine;
 use base64::engine::general_purpose::STANDARD as BASE64_STANDARD;
+use opus::Channels;
+use opus::Decoder as OpusDecoder;
 use serde_json::Value;
 use tokio::io::AsyncReadExt;
 use tokio::io::AsyncWriteExt;
@@ -202,9 +202,10 @@ async fn start_session(
     let (tx_request, rx_request) = mpsc::unbounded_channel::<Value>();
     let (tx_data_channel, rx_data_channel) = oneshot::channel::<Arc<RTCDataChannel>>();
     let tx_data_channel = Mutex::new(Some(tx_data_channel));
+    let tx_data_channel_request = tx_request.clone();
 
     peer_connection.on_data_channel(Box::new(move |data_channel| {
-        let tx_request = tx_request.clone();
+        let tx_request = tx_data_channel_request.clone();
         if let Ok(mut tx_data_channel) = tx_data_channel.lock()
             && let Some(tx_data_channel) = tx_data_channel.take()
         {