Voice Activity Detection

import RunAnywhereONNX
ONNX.register()

let result = try await RunAnywhere.vad.detect(AudioInput.file(path))

func detect(_ audio: AudioInput, options: VadOptions? = nil) async throws -> VadResult
func openStream(format: AudioFormatSpec, options: VadOptions? = nil) -> VadStream
func detectStream(_ audio: AsyncStream<AudioInput>, options: VadOptions? = nil) async throws
    -> AsyncThrowingStream<VadEvent, Error>
func reset() async throws

let stream = RunAnywhere.vad.openStream(
    format: AudioFormatSpec(encoding: .pcmF32Le, sampleRate: 16000, channels: 1)
)

// per audio buffer
stream.pushFrame(AudioFrame(samples: data, sampleCount: count))

// when done
stream.flush()
stream.finish()
await stream.close()

for try await event in try await RunAnywhere.vad.detectStream(audioStream) {
    switch event {
    case .speechStart:
        isSpeaking = true
    case .speechEnd:
        isSpeaking = false
    default:
        break
    }
}

let options = VadOptions(
    activationThreshold: 0.5,
    minSpeechMs: 250,
    minSilenceMs: 500,
    prefixPaddingMs: 300
)

try await RunAnywhere.vad.reset()