fix compile error

Author: yujonglee

crates/audio/src/lib.rs

@@ -182,7 +182,7 @@ impl AudioInput {
                 speaker: self.speaker.take().unwrap().stream().unwrap(),
             },
             AudioSource::RealtimeMixed => AudioStream::RealtimeMixed {
-                mixed: self.mixed.take().unwrap().stream(),
+                mixed: self.mixed.take().unwrap().stream().unwrap(),
             },
             AudioSource::Recorded => AudioStream::Recorded {
                 data: self.data.as_ref().unwrap().clone(),

crates/audio/src/mixed/mod.rs

@@ -1,5 +1,64 @@
+use anyhow::Result;
+use futures_util::{Stream, StreamExt};
+
 #[cfg(target_os = "macos")]
 mod macos;
-
 #[cfg(target_os = "macos")]
-pub use macos::*;
+type PlatformMixedInput = macos::MixedInput;
+#[cfg(target_os = "macos")]
+type PlatformMixedStream = macos::MixedStream;
+
+#[cfg(not(target_os = "macos"))]
+mod other;
+#[cfg(not(target_os = "macos"))]
+type PlatformMixedInput = other::MixedInput;
+#[cfg(not(target_os = "macos"))]
+type PlatformMixedStream = other::MixedStream;
+
+pub struct MixedInput {
+    inner: PlatformMixedInput,
+}
+
+impl MixedInput {
+    pub fn new() -> Result<Self> {
+        let inner = PlatformMixedInput::new()?;
+        Ok(Self { inner })
+    }
+
+    pub fn stream(self) -> Result<MixedStream> {
+        let inner = self.inner.stream();
+        Ok(MixedStream { inner })
+    }
+}
+
+pub struct MixedStream {
+    inner: PlatformMixedStream,
+}
+
+impl Stream for MixedStream {
+    type Item = f32;
+
+    fn poll_next(
+        mut self: std::pin::Pin<&mut Self>,
+        cx: &mut std::task::Context<'_>,
+    ) -> std::task::Poll<Option<Self::Item>> {
+        self.inner.poll_next_unpin(cx)
+    }
+}
+
+impl kalosm_sound::AsyncSource for MixedStream {
+    fn as_stream(&mut self) -> impl Stream<Item = f32> + '_ {
+        self
+    }
+
+    fn sample_rate(&self) -> u32 {
+        #[cfg(target_os = "macos")]
+        {
+            self.inner.sample_rate()
+        }
+        #[cfg(not(target_os = "macos"))]
+        {
+            0
+        }
+    }
+}

crates/audio/src/mixed/other.rs

@@ -0,0 +1,27 @@
+use anyhow::Result;
+use futures_util::Stream;
+
+pub struct MixedInput {}
+
+impl MixedInput {
+    pub fn new() -> Result<Self> {
+        Ok(Self {})
+    }
+
+    pub fn stream(self) -> Result<MixedStream> {
+        Ok(MixedStream {})
+    }
+}
+
+pub struct MixedStream {}
+
+impl Stream for MixedStream {
+    type Item = f32;
+
+    fn poll_next(
+        mut self: std::pin::Pin<&mut Self>,
+        cx: &mut std::task::Context<'_>,
+    ) -> Poll<Option<Self::Item>> {
+        Poll::Pending
+    }
+}

plugins/listener/src/actors/session.rs

@@ -283,7 +283,7 @@ impl SessionSupervisor {
         if state.record_enabled {
             let app_dir = state.app.path().app_data_dir().unwrap();
             let (rec_ref, _) = Actor::spawn_linked(
-                Some("recorder".to_string()),
+                Some(Recorder::name()),
                 Recorder,
                 RecArgs {
                     app_dir: app_dir.clone(),