generateResponse method
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;
}