watchMessages method
Watch messages for a conversation.
Returns a reactive stream that updates when messages change.
Implementation
Stream<List<Message>> watchMessages(String conversationId) {
_ensureInitialized();
return _database.watchMessages(conversationId);
}