sjg/trx-rs
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[refactor](trx-core): add buffered audio write helper

Browse Source 
Co-authored-by: OpenAI Codex <codex@openai.com>
Signed-off-by: Stan Grams <sjg@haxx.space>
This commit is contained in:
Stan Grams
2026-03-06 11:57:55 +01:00
parent 3d0cdbd181
commit e5b9fb7aca
1 changed files with 11 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/trx-core/src/audio.rs
+11 -1
View File
@@ -29,7 +29,7 @@ pub struct AudioStreamInfo {
} }
/// Write a length-prefixed audio message. /// Write a length-prefixed audio message.
pub async fn write_audio_msg<W: AsyncWrite + Unpin>( pub async fn write_audio_msg_buffered<W: AsyncWrite + Unpin>(
writer: &mut W, writer: &mut W,
msg_type: u8, msg_type: u8,
payload: &[u8], payload: &[u8],
@@ -38,6 +38,16 @@ pub async fn write_audio_msg<W: AsyncWrite + Unpin>(
writer.write_u8(msg_type).await?; writer.write_u8(msg_type).await?;
writer.write_u32(len).await?; writer.write_u32(len).await?;
writer.write_all(payload).await?; writer.write_all(payload).await?;
Ok(())
}
/// Write a length-prefixed audio message and flush the writer.
pub async fn write_audio_msg<W: AsyncWrite + Unpin>(
writer: &mut W,
msg_type: u8,
payload: &[u8],
) -> std::io::Result<()> {
write_audio_msg_buffered(writer, msg_type, payload).await?;
writer.flush().await?; writer.flush().await?;
Ok(()) Ok(())
} }