lazyspeak 0.4.4

CLI daemon for lazyspeak.nvim — voice-driven coding
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

use crate::audio::AudioEvent;
use streamsafe::{Result, Source};

/// Bridges the synchronous `std::sync::mpsc::Receiver<AudioEvent>` from cpal
/// into an async streamsafe `Source`.
pub struct AudioSource {
    rx: tokio::sync::mpsc::Receiver<AudioEvent>,
}

impl AudioSource {
    pub fn new(sync_rx: std::sync::mpsc::Receiver<AudioEvent>) -> Self {
        let (tx, rx) = tokio::sync::mpsc::channel(64);
        std::thread::spawn(move || {
            for event in sync_rx {
                if tx.blocking_send(event).is_err() {
                    break;
                }
            }
        });
        Self { rx }
    }
}

impl Source for AudioSource {
    type Output = AudioEvent;

    async fn produce(&mut self) -> Result<Option<AudioEvent>> {
        Ok(self.rx.recv().await)
    }
}