streamcore-rust-sdk

Installation

[dependencies]
streamcoreai-voice-agent-sdk = { git = "https://github.com/streamcoreai/rust-sdk" }

streamcore-rust-sdk = "0.1"

Quick Start

use std::sync::Arc;
use streamcore_rust_sdk::{Client, Config, EventHandler, FRAME_SIZE};
#[tokio::main]
async fn main() -> anyhow::Result<()> {
 let client = Arc::new(Client::new(
 Config {
 whip_endpoint: "http://localhost:8080/whip".into(),
 ..Default::default()
 },
 EventHandler {
 on_status_change: Some(Box::new(|status| {
 println!("[status] {}", status);
 })),
 on_transcript: Some(Box::new(|entry, _all| {
 println!("[{}] {}", entry.role, entry.text);
 })),
 on_error: Some(Box::new(|err| {
 eprintln!("[error] {}", err);
 })),
 on_data_channel_message: None,
 },
 ));
 client.connect().await?;
 // Send microphone audio (f32 PCM, mono, 48 kHz, 960 samples per frame)
 let client_tx = Arc::clone(&client);
 tokio::spawn(async move {
 let pcm = vec![0.0f32; FRAME_SIZE]; // replace with real mic capture
 loop {
 client_tx.send_pcm(&pcm).await.unwrap();
 }
 });
 // Receive agent audio
 let client_rx = Arc::clone(&client);
 tokio::spawn(async move {
 let mut pcm = vec![0.0f32; FRAME_SIZE];
 loop {
 let n = client_rx.recv_pcm(&mut pcm).await.unwrap();
 // Play pcm[..n] through speakers
 let _ = &pcm[..n];
 }
 });
 tokio::signal::ctrl_c().await?;
 client.disconnect().await;
 Ok(())
}

API

Client::new(config, events)

Config

EventHandler

Client Methods

Audio Constants

Client Fields (after connect())

Types

pub enum ConnectionStatus { Idle, Connecting, Connected, Error, Disconnected }
pub struct TranscriptEntry {
 pub role: String, // "user" or "assistant"
 pub text: String,
 pub partial: bool,
}
pub struct DataChannelMessage {
 pub msg_type: String, // "transcript", "response", or "error"
 pub text: String,
 pub r#final: bool,
 pub message: String,
}

Audio I/O

Requirements

Dependencies

License