diff --git a/crates/acp_thread/src/acp_thread.rs b/crates/acp_thread/src/acp_thread.rs index 2e7839d74b..57861704db 100644 --- a/crates/acp_thread/src/acp_thread.rs +++ b/crates/acp_thread/src/acp_thread.rs @@ -827,7 +827,7 @@ impl AcpThread { mut prompt_capabilities_rx: watch::Receiver, cx: &mut Context, ) -> Self { - let prompt_capabilities = prompt_capabilities_rx.borrow().clone(); + let prompt_capabilities = *prompt_capabilities_rx.borrow(); let task = cx.spawn::<_, anyhow::Result<()>>(async move |this, cx| { loop { let caps = prompt_capabilities_rx.recv().await?; diff --git a/crates/agent_servers/src/acp.rs b/crates/agent_servers/src/acp.rs index 4a9a990bfe..5a4efe12e5 100644 --- a/crates/agent_servers/src/acp.rs +++ b/crates/agent_servers/src/acp.rs @@ -193,7 +193,7 @@ impl AgentConnection for AcpConnection { action_log, session_id.clone(), // ACP doesn't currently support per-session prompt capabilities or changing capabilities dynamically. - watch::Receiver::constant(self.prompt_capabilities.clone()), + watch::Receiver::constant(self.prompt_capabilities), cx, ) })?;