Streaming STT

final stream = await RunAnywhere.stt.openStream(
  AudioFormatSpec(
    encoding: AudioEncoding.pcmF32Le,
    sampleRate: 16000,
    channels: 1,
  ),
);

// per buffer
stream.pushFrame(AudioFrame(samples: bytes, sampleCount: count));

// when the utterance ends
stream.flush();
stream.finish();
await stream.close();

await for (final event in RunAnywhere.stt.transcribeStream(audioStream)) {
  if (event is TranscriptionEventPartial) {
    setState(() => _preview = event.text);
  }
  if (event is TranscriptionEventFinal) {
    setState(() => _transcript += event.transcription.text);
  }
}

Future<SttStream> openStream(AudioFormatSpec format, {SttOptions? options})
Stream<TranscriptionEvent> transcribeStream(Stream<AudioInput> audio, {SttOptions? options})

final sttStream = await RunAnywhere.stt.openStream(
  AudioFormatSpec(
    encoding: AudioEncoding.pcmF32Le,
    sampleRate: 16000,
    channels: 1,
  ),
);

final subscription = recorder.audioStream.listen((chunk) {
  sttStream.pushFrame(AudioFrame(samples: chunk, sampleCount: chunk.length ~/ 4));
});

// when the user stops
await subscription.cancel();
sttStream.flush();
sttStream.finish();
await sttStream.close();
await recorder.stop();