Streaming TTS

for await (const chunk of RunAnywhere.tts.synthesizeStream(longText)) {
  player.enqueue(chunk)
}

synthesizeStream(text: string, options?: TtsOptions): AsyncIterable<AudioChunk>

let sentence = ''

for await (const event of RunAnywhere.llm.generateStream(prompt)) {
  if (event.type !== 'textDelta') continue
  sentence += event.text

  if (/[.!?]/.test(event.text)) {
    await RunAnywhere.tts.speak(sentence)
    sentence = ''
  }
}

if (sentence) await RunAnywhere.tts.speak(sentence)

const context = new AudioContext()
let playAt = context.currentTime

for await (const chunk of RunAnywhere.tts.synthesizeStream(text)) {
  const buffer = context.createBuffer(1, chunk.sampleCount, chunk.sampleRate)
  buffer.copyToChannel(new Float32Array(chunk.samples.buffer), 0)

  const source = context.createBufferSource()
  source.buffer = buffer
  source.connect(context.destination)
  source.start(playAt)

  playAt += buffer.duration
}