consumeMessages method

List<String> consumeMessages(
  1. String agentId
)

Retrieve and clear pending messages for an agent.

Implementation

List<String> consumeMessages(String agentId) {
  final messages = _pendingMessages.remove(agentId);
  if (messages == null) return const [];
  return messages.map((m) => m.message).toList();
}