yes

Author: marci1175

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "silence-core"
-version = "0.1.9"
+version = "0.1.11"
 edition = "2021"
 description = "Core audio I/O abstractions for the silence crate."
 license = "Apache-2.0"
@@ -41,3 +41,4 @@ opus = {version = "0.3.0", optional = true}
 ravif = {version = "0.11.11", optional = true}
 opencv = {version = "0.93.4", optional = true}
 image = {version = "0.25.5", optional = true}
+deepsize = "0.2.0"

Cargo.toml

@@ -61,3 +61,30 @@ pub fn get_audio_device(device: Host) -> HostDevice {
         output: device.default_output_device(),
     }
 }
+
+/// Shows the encoder type of the packet.
+#[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
+#[derive(Debug, deepsize::DeepSizeOf)]
+pub enum EncoderType {
+    /// The encoder of this packet was [`opus`].
+    /// The inner value contains whether.
+    Opus(bool),
+}
+
+/// The encoded sound packet.
+/// Contains useful information about the encoded packet.
+#[derive(Debug, deepsize::DeepSizeOf)]
+#[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
+pub struct SoundPacket {
+    /// The Encoder's type which this [`SoundPacket`] got encoded with.
+    pub encoder_type: EncoderType,
+    /// The sample rate of the encoded packet.
+    pub sample_rate: u32,
+    /// The channel count of the encoded packet.
+    pub channels: u32,
+    /// The bytes of the encoded sound packet.
+    pub bytes: Vec<u8>,
+    /// The count of samples per frame.
+    pub samples_per_frame: u64,
+}
+

src/io/mod.rs

@@ -3,7 +3,7 @@
 use anyhow::Result;
 use opus::Decoder;
 
-use super::SoundPacket;
+use crate::io::SoundPacket;
 
 ///
 /// Create an [`opus`] decoder.
@@ -59,7 +59,7 @@ pub fn decode_samples_opus(
     let mut samples = vec![];
 
     for sound_packet in sound_packets {
-        let super::encode::EncoderType::Opus(fec) = sound_packet.encoder_type;
+        let crate::io::EncoderType::Opus(fec) = sound_packet.encoder_type;
 
         let decoded_samples = decode_sample_set_size_opus(&mut decoder, sound_packet, fec)?;
 

src/opus/decode.rs

@@ -2,7 +2,9 @@
 
 use opus::{Channels, Encoder};
 
-use super::SoundPacket;
+use crate::io::EncoderType;
+
+use crate::io::SoundPacket;
 
 ///
 /// Create an [`opus`] encoder.
@@ -99,13 +101,4 @@ pub fn encode_samples_opus(
     }
 
     Ok(sound_packets)
-}
-
-/// Shows the encoder type of the packet.
-#[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
-#[derive(Debug)]
-pub enum EncoderType {
-    /// The encoder of this packet was [`opus`].
-    /// The inner value contains whether.
-    Opus(bool),
-}
+}

src/opus/encode.rs

@@ -1,25 +1,7 @@
 //! This feature allows opus encoding and decoding for efficient byte transfer, while not sacirifising audio quality.
 
-use encode::EncoderType;
 pub mod decode;
 pub mod encode;
 
 /// Re-export the opus crate.
-pub use opus;
-
-/// The encoded sound packet.
-/// Contains useful information about the encoded packet.
-#[derive(Debug)]
-#[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
-pub struct SoundPacket {
-    /// The Encoder's type which this [`SoundPacket`] got encoded with.
-    pub encoder_type: EncoderType,
-    /// The sample rate of the encoded packet.
-    pub sample_rate: u32,
-    /// The channel count of the encoded packet.
-    pub channels: u32,
-    /// The bytes of the encoded sound packet.
-    pub bytes: Vec<u8>,
-    /// The count of bytes of the packet.
-    pub samples_per_frame: u64,
-}
+pub use opus;

src/opus/mod.rs

@@ -6,6 +6,7 @@ mod tests {
     use std::{collections::VecDeque, fs, thread::sleep, time::Duration};
 
     use cpal::traits::{DeviceTrait, StreamTrait};
+    use deepsize::DeepSizeOf;
     use opencv::videoio::{CAP_ANY, CAP_MSMF};
     use opus::Channels;
     use ravif::Encoder;
@@ -99,7 +100,7 @@ mod tests {
             record_audio_with_interrupt(input_device, receiver, err_callback, config.into())
                 .unwrap();
 
-        sleep(Duration::from_secs(3));
+        sleep(Duration::from_millis(30));
 
         sender.send(()).unwrap();
 
@@ -125,14 +126,18 @@ mod tests {
         )
         .unwrap();
 
-        let sound_packets: Vec<crate::opus::SoundPacket> = encode_samples_opus(encoder, &Into::<Vec<f32>>::into(sample), 20, channels).unwrap();
+        let sound_packets: Vec<crate::io::SoundPacket> = encode_samples_opus(encoder, &Into::<Vec<f32>>::into(sample), 20, channels).unwrap();
 
         let decoder = create_opus_decoder(48000).unwrap();
 
+        dbg!(sound_packets.deep_size_of());
+
         let decoded_buf = decode_samples_opus(decoder, sound_packets).unwrap();
 
         let err_callback = |err| eprintln!("an error occurred on stream: {}", err);
 
+        sleep(Duration::from_secs(1));
+
         let stream = stream_audio(
             audio_device.output.unwrap(),
             err_callback,