run method

Future<String> run({
  1. required String model,
  2. double? temperature,
})

Implementation

Future<String> run({required String model, double? temperature}) async {
  final buffer = StringBuffer();
  await for (final event in client.streamChat(
    _messages,
    model: model,
    temperature: temperature,
    extraBody: const {},
  )) {
    if (event is AiTextDelta) buffer.write(event.text);
    if (event is AiDone) break;
    if (event is AiError) throw event;
  }
  _messages.add(AiChatMessage.assistant(buffer.toString()));
  return buffer.toString();
}