| 270 | } |
| 271 | } |
| 272 | void send_query_answer(ConnectionId connection_id, td::int64 query_id, td::BufferSlice data) { |
| 273 | auto it = active_connections_.find(connection_id); |
| 274 | if (it != active_connections_.end()) { |
| 275 | td::actor::send_closure(it->second.connection, &TcpClientConnection::send_query_answer, query_id, |
| 276 | std::move(data)); |
| 277 | } |
| 278 | } |
| 279 | void send_query_answer_error(ConnectionId connection_id, td::int64 query_id, td::Status error) { |
| 280 | auto it = active_connections_.find(connection_id); |
| 281 | if (it != active_connections_.end()) { |
nothing calls this directly
no outgoing calls
no test coverage detected