adk-audio 0.4.0

Audio intelligence and pipeline orchestration for ADK-Rust agents
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
31
32
33
34
35
36
37
38
39
40
41

//! Pipeline handle for interacting with a running pipeline.

use std::sync::Arc;

use tokio::sync::{RwLock, mpsc, oneshot};

use crate::pipeline::types::{PipelineInput, PipelineMetrics, PipelineOutput};

/// Handle to a running audio pipeline.
///
/// Provides channels for sending input, receiving output, reading metrics,
/// and shutting down the pipeline.
pub struct PipelineHandle {
    /// Send audio, text, or control messages into the pipeline.
    pub input_tx: mpsc::Sender<PipelineInput>,
    /// Receive audio, transcript, or metrics output from the pipeline.
    pub output_rx: mpsc::Receiver<PipelineOutput>,
    /// Real-time pipeline metrics (updated after each stage).
    pub metrics: Arc<RwLock<PipelineMetrics>>,
    /// One-shot channel to signal graceful shutdown.
    shutdown_tx: Option<oneshot::Sender<()>>,
}

impl PipelineHandle {
    /// Create a new `PipelineHandle`.
    pub(crate) fn new(
        input_tx: mpsc::Sender<PipelineInput>,
        output_rx: mpsc::Receiver<PipelineOutput>,
        metrics: Arc<RwLock<PipelineMetrics>>,
        shutdown_tx: oneshot::Sender<()>,
    ) -> Self {
        Self { input_tx, output_rx, metrics, shutdown_tx: Some(shutdown_tx) }
    }

    /// Signal the pipeline to shut down gracefully.
    pub fn shutdown(&mut self) {
        if let Some(tx) = self.shutdown_tx.take() {
            let _ = tx.send(());
        }
    }
}