sendMessageStream method

  1. @override
Stream<String> sendMessageStream({
  1. required String message,
  2. List<ChatMessage> conversationHistory = const [],
  3. Map<String, dynamic>? options,
})
override

Send a message and get a streaming response

Implementation

@override
Stream<String> sendMessageStream({
  required String message,
  List<ChatMessage> conversationHistory = const [],
  Map<String, dynamic>? options,
}) async* {
  // Implement streaming response
  final response = "Custom streaming response to: $message";
  final words = response.split(' ');
  for (var word in words) {
    yield word + (word != words.last ? ' ' : '');
    await Future.delayed(const Duration(milliseconds: 50));
  }
}