generateResponse method

@override Stream<String> generateResponse(String text)

Generates a response based on the input text.

Creates a StreamController for the response, then delegates to _tryResponse which adds retry logic to the task.

Implementation

@override
Stream<String> generateResponse(String text) {
  _log.fine('Generating response to "${text.shorten()}"');
  assert(
    _responseController == null,
    'Should not call `generateResponse` while previous controller is '
    'still active.',
  );
  _responseController = StreamController<String>();
  _tryResponse(text);
  return _responseController!.stream;
}