| 199 | } |
| 200 | |
| 201 | List<ChatReceivedMessage> ChatProcessor::pullPendingMessages(ConnectionId clientId) { |
| 202 | RecursiveMutexLocker locker(m_mutex); |
| 203 | if (m_clients.contains(clientId)) |
| 204 | return take(m_clients.get(clientId).pendingMessages); |
| 205 | return {}; |
| 206 | } |
| 207 | |
| 208 | void ChatProcessor::setCommandHandler(CommandHandler commandHandler) { |
| 209 | RecursiveMutexLocker locker(m_mutex); |
no test coverage detected