diff --git a/src/ipc.rs b/src/ipc.rs index 532722e38..f2765ebd1 100644 --- a/src/ipc.rs +++ b/src/ipc.rs @@ -456,8 +456,8 @@ where } } - pub async fn send_raw(&mut self, data: Vec) -> ResultType<()> { - self.inner.send(bytes::Bytes::from(data)).await?; + pub async fn send_raw(&mut self, data: Bytes) -> ResultType<()> { + self.inner.send(data).await?; Ok(()) } diff --git a/src/server/connection.rs b/src/server/connection.rs index f4ed9da2a..9c326575e 100644 --- a/src/server/connection.rs +++ b/src/server/connection.rs @@ -1364,7 +1364,7 @@ async fn start_ipc( data, compressed}) = data { stream.send(&Data::FS(ipc::FS::WriteBlock{id, file_num, data: Bytes::new(), compressed})).await?; - stream.send_raw(data.into()).await?; + stream.send_raw(data).await?; } else { stream.send(&data).await?; } diff --git a/src/ui/cm.rs b/src/ui/cm.rs index c1acb6926..fe5738c31 100644 --- a/src/ui/cm.rs +++ b/src/ui/cm.rs @@ -590,7 +590,7 @@ async fn start_pa() { } else { buf.clone() }; - if let Err(err) = stream.send_raw(out).await { + if let Err(err) = stream.send_raw(out.into()).await { log::error!("Failed to send audio data:{}", err); break; }