Voice Agent

let session = try await RunAnywhere.voice.createSession(
    stt: ModelRef(id: "whisper-base"),
    llm: ModelRef(id: "qwen3-0.6b"),
    tts: ModelRef(id: "piper-en-amy")
)

try session.start()

for try await event in session.events {
    switch event {
    case .userTranscript(let text):
        transcript.append(("user", text))
    case .assistantText(let text):
        transcript.append(("assistant", text))
    default:
        break
    }
}

func createSession(
    stt: ModelRef,
    llm: ModelRef,
    tts: ModelRef,
    vad: VadOptions? = nil,
    turnHandling: TurnHandlingOptions? = nil,
    generation: LlmOptions? = nil,
    downloadIfNeeded: Bool = true
) async throws -> VoiceSession

var events: AsyncThrowingStream<VoiceEvent, Error>
func start() throws
func say(_ text: String) async throws -> SpeechHandle
func interrupt() async
func close() async

let session = try await RunAnywhere.voice.createSession(
    stt: sttModel,
    llm: llmModel,
    tts: ttsModel,
    turnHandling: TurnHandlingOptions(
        endpointing: Endpointing(minDelayMs: 500, maxDelayMs: 3000),
        interruption: Interruption(enabled: true, minDurationMs: 500)
    )
)

generation: LlmOptions(
    systemPrompt: "You are a voice assistant. Answer in one or two sentences.",
    maxOutputTokens: 100
)

@MainActor
@Observable
final class VoiceAgent {
    var transcript: [(String, String)] = []
    private var session: VoiceSession?

    func start() async throws {
        let session = try await RunAnywhere.voice.createSession(
            stt: ModelRef(id: "whisper-base"),
            llm: ModelRef(id: "qwen3-0.6b"),
            tts: ModelRef(id: "piper-en-amy"),
            generation: LlmOptions(
                systemPrompt: "Answer in one or two sentences.",
                maxOutputTokens: 100
            )
        )
        self.session = session

        try session.start()
        _ = try await session.say("Hello. What can I help with?")

        for try await event in session.events {
            switch event {
            case .userTranscript(let text):
                transcript.append(("user", text))
            case .assistantText(let text):
                transcript.append(("assistant", text))
            default:
                break
            }
        }
    }

    func stop() async {
        await session?.close()
        session = nil
    }
}

let result = try await RunAnywhere.diarization.diarize(AudioInput.file(path))

let events = try await RunAnywhere.diarization.diarizeStream(audioStream)